Edit

Share via


EventHubMessage Constructors

Definition

Overloads

EventHubMessage(CachedMessage, SerializationManager)

Duplicate of EventHub's EventData class.

EventHubMessage(CachedEventHubMessage, 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

Applies to

EventHubMessage(CachedEventHubMessage, SerializationManager)

Duplicate of EventHub's EventData class.

public EventHubMessage (Orleans.ServiceBus.Providers.CachedEventHubMessage cachedMessage, Orleans.Serialization.SerializationManager serializationManager);
new Orleans.ServiceBus.Providers.EventHubMessage : Orleans.ServiceBus.Providers.CachedEventHubMessage * Orleans.Serialization.SerializationManager -> Orleans.ServiceBus.Providers.EventHubMessage
Public Sub New (cachedMessage As CachedEventHubMessage, serializationManager As SerializationManager)

Parameters

cachedMessage
CachedEventHubMessage
serializationManager
SerializationManager

Applies to

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

Applies to