EventHubDataAdapter Methods

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

EncodeMessageIntoSegment(EventData, Func<int, ArraySegment<byte>>)

virtual

protected virtual ArraySegment<byte> EncodeMessageIntoSegment(EventData queueMessage, Func<int, ArraySegment<byte>> getSegment)

Parameters

queueMessageEventData
getSegmentFunc<int, ArraySegment<byte>>

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)

Parameters

streamPositionStreamPosition
queueMessageEventData
dequeueTimeDateTime
getSegmentFunc<int, ArraySegment<byte>>

GetBatchContainer(EventHubMessage)

virtual

View source

protected virtual IBatchContainer GetBatchContainer(EventHubMessage eventHubMessage)

Convert an EventHubMessage to a batch container

Parameters

eventHubMessageEventHubMessage

GetBatchContainer(CachedMessage)

virtual

View source

public virtual IBatchContainer GetBatchContainer(ref CachedMessage cachedMessage)

Converts a cached message to a batch container for delivery

Parameters

cachedMessageCachedMessage

GetOffset(CachedMessage)

virtual

View source

public virtual string GetOffset(CachedMessage lastItemPurged)

Get offset from cached message. Left to derived class, as only it knows how to get this from the cached message.

Parameters

lastItemPurgedCachedMessage

GetPartitionKey(StreamId)

virtual

View source

public virtual string GetPartitionKey(StreamId streamId)

Get the Event Hub partition key to use for a stream.

Parameters

streamIdStreamId: The stream Guid.

Returns

The partition key to use for the stream.

GetSequenceToken(CachedMessage)

virtual

View source

public virtual StreamSequenceToken GetSequenceToken(ref CachedMessage cachedMessage)

Gets the stream sequence token from a cached message.

Parameters

cachedMessageCachedMessage

GetStreamIdentity(EventData)

virtual

View source

public virtual StreamId GetStreamIdentity(EventData queueMessage)

Get the IStreamIdentity for an event message.

Parameters

queueMessageEventData: The event message.

Returns

The stream identity.

GetStreamPosition(string, EventData)

virtual

View source

public virtual StreamPosition GetStreamPosition(string partition, EventData queueMessage)

Parameters

partitionstring
queueMessageEventData

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

virtual

View source

public virtual EventData 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.