Skip to content
Orleans logoMicrosoft Orleans

SQSDataAdapter Methods

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

FromQueueMessage(Message, long)

virtual
View source
public virtual IBatchContainer FromQueueMessage(Message sqsMessage, long sequenceId)
Converts an SQS message to an Orleans stream batch.

Parameters

sqsMessageMessage
The SQS message to convert.
sequenceIdlong
The locally assigned sequence number for the stream batch.

Returns

The stream batch represented by sqsMessage.

ToQueueMessage(StreamId, IEnumerable<T>, StreamSequenceToken?, Dictionary<string, object>)

virtual
View source
public virtual Message ToQueueMessage<T>(StreamId streamId, IEnumerable<T> events, StreamSequenceToken? token, Dictionary<string, object>? requestContext)
Converts a batch of Orleans stream events to an SQS message.

Parameters

streamIdStreamId
The stream identifier.
eventsIEnumerable<T>
The stream events to include in the message.
tokenStreamSequenceToken?
The stream sequence token, which must be null.
requestContextDictionary<string, object>
The request context to include in the message.

Returns

An SQS message containing the serialized stream batch.

Exceptions

System.ArgumentException
token is not null.