MemoryStreamQueueGrain

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

class

Namespace: Orleans.Providers

NuGetSourceMarkdown

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.

public class MemoryStreamQueueGrain : Grain, IGrain, IGrainWithGuidKey, IMemoryStreamQueueGrain, IAddressable, IGrainMigrationParticipant

Constructors

• MemoryStreamQueueGrain

Methods

• Dequeue(int) Dequeues up to a max amount of maxCount event data from the queue.
• Dequeue(int, CancellationToken) Dequeues up to maxCount events.
• Enqueue(MemoryMessageData) Enqueues an event data. If the current total count reaches the max limit. throws an exception.
• Enqueue(MemoryMessageData, CancellationToken) Enqueues an event.