Skip to content

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)

View source
public Task<List<MemoryMessageData>> Dequeue(int maxCount)
Dequeues up to a max amount of maxCount event data from the queue.

Parameters

maxCountint

Enqueue(MemoryMessageData)

View source
public Task Enqueue(MemoryMessageData data)
Enqueues an event data. If the current total count reaches the max limit. throws an exception.

Parameters

dataMemoryMessageData