IQueueAdapterReceiver

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

interface

Namespace: Orleans.Streams

NuGetMarkdown

Receives batches of messages from a single partition of a message queue.

public interface IQueueAdapterReceiver

Methods

• GetQueueMessagesAsync(int) Retrieves batches from a message queue.
• Initialize(TimeSpan) Initializes this receiver.
• MessagesDeliveredAsync(IList<IBatchContainer>) Notifies the adapter receiver that the messages were delivered to all consumers, so the receiver can take an appropriate action (e.g., delete the messages from a message queue).
• Shutdown(TimeSpan) Receiver is no longer used. Shutdown and clean up.