Dequeue(int)
public Task<List<MemoryMessageData>> Dequeue(int maxCount) Dequeues up to a max amount of maxCount event data from the queue.
Parameters
maxCountint- The maximum number of events to dequeue.
Returns
The dequeued events.
MemoryStreamQueueGrain Methods
Memory stream queue grain. This grain works as a storage queue of event data. Enqueue and Dequeue operations are supported. the max event count sets the max storage limit to the queue.
Dequeue(int, CancellationToken)
public Task<List<MemoryMessageData>> Dequeue(int maxCount, CancellationToken cancellationToken) Dequeues up to
maxCount events. Parameters
maxCountint- The maximum number of events to dequeue.
cancellationTokenCancellationToken- The cancellation token.
Returns
A
System.Threading.Tasks.Task representing the operation.Enqueue(MemoryMessageData)
public Task Enqueue(MemoryMessageData data) Enqueues an event data. If the current total count reaches the max limit. throws an exception.
Parameters
dataMemoryMessageData- The event data.
Returns
A
System.Threading.Tasks.Task representing the operation.Enqueue(MemoryMessageData, CancellationToken)
public Task Enqueue(MemoryMessageData data, CancellationToken cancellationToken) Enqueues an event.
Parameters
dataMemoryMessageData- The data.
cancellationTokenCancellationToken- The cancellation token.
Returns
A
System.Threading.Tasks.Task representing the operation.