EventHubBatchContainer Class

Reference

Definition

Namespace:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Package:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Package:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Package:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:: EventHubBatchContainer.cs

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Batch container that is delivers payload and stream position information for a set of events in an EventHub EventData.

[System.Serializable]
public class EventHubBatchContainer : Orleans.Serialization.IOnDeserialized, Orleans.Streams.IBatchContainer

[<System.Serializable>]
type EventHubBatchContainer = class
    interface IBatchContainer
    interface IOnDeserialized

Public Class EventHubBatchContainer
Implements IBatchContainer, IOnDeserialized

Inheritance: Object
EventHubBatchContainer

Attributes: SerializableAttribute

Implements: IOnDeserialized IBatchContainer

Constructors

EventHubBatchContainer(EventHubMessage, SerializationManager)

Batch container that deliveres events from cached EventHub data associated with an orleans stream

Properties

SequenceToken	Stream Sequence Token for the start of this batch.
StreamGuid	Stream identifier for the stream this batch is part of.
StreamNamespace	Stream namespace for the stream this batch is part of.

Methods

GetEvents<T>()	Gets events of a specific type from the batch.
ImportRequestContext()	Gives an opportunity to IBatchContainer to set any data in the RequestContext before this IBatchContainer is sent to consumers. It can be the data that was set at the time event was generated and enqueued into the persistent provider or any other data.
ShouldDeliver(IStreamIdentity, Object, StreamFilterPredicate)	Decide whether this batch should be sent to the specified target.
ToEventData<T>(SerializationManager, Guid, String, IEnumerable<T>, Dictionary<String,Object>)	Put events list and its context into a EventData object

Explicit Interface Implementations

IOnDeserialized.OnDeserialized(ISerializerContext)

Applies to

Dela via