IQueueAdapter

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. IQueueAdapter

interface

Namespace: Orleans.Streams

NuGetMarkdown

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

public interface IQueueAdapter

Properties

• Direction Gets the direction of this queue adapter: StreamProviderDirection, StreamProviderDirection, or StreamProviderDirection.
• 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(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<string, object>) Writes a set of events to the queue as a single batch associated with the provided streamId.