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)
Convert an SQS Message to a batch container

Parameters

sqsMessageMessage
sequenceIdlong

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)
Creates a cloud queue message from stream event data.

Parameters

streamIdStreamId
The stream identifier.
eventsIEnumerable<T>
The events.
tokenStreamSequenceToken?
The token.
requestContextDictionary<string, object>
The request context.

Returns

A new queue message.