EventHubMessage Constructors

Definition

Namespace:

Orleans.ServiceBus.Providers

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Overloads

EventHubMessage(CachedMessage, SerializationManager)	Duplicate of EventHub's EventData class.
EventHubMessage(IStreamIdentity, String, String, Int64, DateTime, DateTime, IDictionary<String,Object>, Byte[])	Contructor

EventHubMessage(CachedMessage, SerializationManager)

Source:

EventHubMessage.cs

Duplicate of EventHub's EventData class.

public EventHubMessage (Orleans.Providers.Streams.Common.CachedMessage cachedMessage, Orleans.Serialization.SerializationManager serializationManager);

new Orleans.ServiceBus.Providers.EventHubMessage : Orleans.Providers.Streams.Common.CachedMessage * Orleans.Serialization.SerializationManager -> Orleans.ServiceBus.Providers.EventHubMessage

Public Sub New (cachedMessage As CachedMessage, serializationManager As SerializationManager)

Parameters

cachedMessage

CachedMessage

serializationManager

SerializationManager

EventHubMessage(IStreamIdentity, String, String, Int64, DateTime, DateTime, IDictionary<String,Object>, Byte[])

Source:

EventHubMessage.cs

Contructor

public EventHubMessage (Orleans.Streams.IStreamIdentity streamIdentity, string partitionKey, string offset, long sequenceNumber, DateTime enqueueTimeUtc, DateTime dequeueTimeUtc, System.Collections.Generic.IDictionary<string,object> properties, byte[] payload);

new Orleans.ServiceBus.Providers.EventHubMessage : Orleans.Streams.IStreamIdentity * string * string * int64 * DateTime * DateTime * System.Collections.Generic.IDictionary<string, obj> * byte[] -> Orleans.ServiceBus.Providers.EventHubMessage

Public Sub New (streamIdentity As IStreamIdentity, partitionKey As String, offset As String, sequenceNumber As Long, enqueueTimeUtc As DateTime, dequeueTimeUtc As DateTime, properties As IDictionary(Of String, Object), payload As Byte())

Parameters

streamIdentity

IStreamIdentity

Stream Identity

partitionKey

String

EventHub partition key for message

offset

String

Offset into the EventHub parition where this message was from

sequenceNumber

Int64

Offset into the EventHub parition where this message was from

enqueueTimeUtc

DateTime

Time in UTC when this message was injected by EventHub

dequeueTimeUtc

DateTime

Time in UTC when this message was read from EventHub into the current service

properties

IDictionary<String,Object>

User properties from EventData object

payload

Byte[]

Binary data from EventData objbect