SQSDataAdapter

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.SQS
4. SQSDataAdapter

class

Namespace: Orleans.Streaming.SQS.Streams

NuGetSourceMarkdown

Default SQS Stream data adapter. Users may subclass to override event data to stream mapping.

public class SQSDataAdapter : ISQSDataAdapter, IQueueDataAdapter<Message, IBatchContainer>, IQueueDataAdapter<Message>

Constructors

• SQSDataAdapter(Serializer)

Methods

• FromQueueMessage(Message, long) Convert an SQS Message to a batch container
• ToQueueMessage(StreamId, IEnumerable<T>, StreamSequenceToken?, Dictionary<string, object>) Creates a cloud queue message from stream event data.