Edytuj

Udostępnij za pośrednictwem


IQueueAdapter Interface

Definition

Stream queue storage adapter. This is an abstraction layer that hides the implementation details of the underlying queuing system.

public interface IQueueAdapter
type IQueueAdapter = interface
Public Interface IQueueAdapter
Derived

Properties

Direction

Gets the direction of this queue adapter: ReadOnly, WriteOnly, or ReadWrite.

IsRewindable

Gets a value indicating whether this is a rewindable stream adapter - supports subscribing from previous point in time.

Name

Gets the name of the adapter. Primarily for logging purposes

Methods

CreateReceiver(QueueId)

Creates a queue receiver for the specified queueId

QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

Writes a set of events to the queue as a single batch associated with the provided streamId.

QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

Writes a set of events to the queue as a single batch associated with the provided streamId.

Extension Methods

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)

Writes a set of events to the queue as a single batch associated with the provided streamId.

QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)

Writes a set of events to the queue as a single batch associated with the provided streamId.

Applies to