EventHubDataAdapter.FromQueueMessage(StreamPosition, EventData, DateTime, Func<int, ArraySegment<byte>>)

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. EventHubDataAdapter
5. Methods
6. FromQueueMessage(StreamPosition, EventData, DateTime, Func<int, ArraySegment<byte>>)

Markdown

FromQueueMessage(StreamPosition, EventData, DateTime, Func<int, ArraySegment<byte>>)

virtual

View source

public virtual CachedMessage FromQueueMessage(StreamPosition streamPosition, EventData queueMessage, DateTime dequeueTime, Func<int, ArraySegment<byte>> getSegment)

Converts an Event Hub message into a cached message.

Parameters

streamPositionStreamPosition

The stream position of the message.

queueMessageEventData

The Event Hub message.

dequeueTimeDateTime

The UTC time when the message was dequeued.

getSegmentFunc<int, ArraySegment<byte>>

The delegate used to allocate a cache segment of the required size.

Returns

The cached message.