Skip to content

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

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.