CreateReceiver(QueueId)
abstract
public abstract IQueueAdapterReceiver CreateReceiver(QueueId queueId) Creates a queue receiver for the specified queueId
Parameters
queueIdQueueId- The queue identifier.
Returns
The receiver.
IQueueAdapter Methods
Stream queue storage adapter. This is an abstraction layer that hides the implementation details of the underlying queuing system.
QueueMessageBatchAsync(StreamId, IEnumerable<T>, StreamSequenceToken?, Dictionary<string, object>)
abstract
public abstract Task QueueMessageBatchAsync<T>(StreamId streamId, IEnumerable<T> events, StreamSequenceToken? token, Dictionary<string, object>? requestContext) Writes a set of events to the queue as a single batch associated with the provided streamId.
Parameters
streamIdStreamId- The stream identifier.
eventsIEnumerable<T>- The events.
tokenStreamSequenceToken?- The token.
requestContextDictionary<string, object>- The request context.
Returns
Task.