Redigera

Dela via


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