Edytuj

Udostępnij za pośrednictwem

EventHubMessage Constructors

  • Reference

Definition

Namespace:
Orleans.Streaming.EventHubs
Assembly:
Orleans.Streaming.EventHubs.dll
Package:
Microsoft.Orleans.Streaming.EventHubs v7.2.5
Package:
Microsoft.Orleans.Streaming.EventHubs v8.0.0
Package:
Microsoft.Orleans.Streaming.EventHubs v8.1.0
Package:
Microsoft.Orleans.Streaming.EventHubs v8.2.0

Overloads

EventHubMessage(CachedMessage, Serializer)

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

Constructor

EventHubMessage(CachedMessage, Serializer)

Duplicate of EventHub's EventData class.

public EventHubMessage (Orleans.Providers.Streams.Common.CachedMessage cachedMessage, Orleans.Serialization.Serializer serializer);
new Orleans.Streaming.EventHubs.EventHubMessage : Orleans.Providers.Streams.Common.CachedMessage * Orleans.Serialization.Serializer -> Orleans.Streaming.EventHubs.EventHubMessage
Public Sub New (cachedMessage As CachedMessage, serializer As Serializer)

Parameters

cachedMessage
CachedMessage
serializer
Serializer

Applies to

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

Constructor

public EventHubMessage (Orleans.Runtime.StreamId streamId, string partitionKey, string offset, long sequenceNumber, DateTime enqueueTimeUtc, DateTime dequeueTimeUtc, System.Collections.Generic.IDictionary<string,object> properties, byte[] payload);
new Orleans.Streaming.EventHubs.EventHubMessage : Orleans.Runtime.StreamId * string * string * int64 * DateTime * DateTime * System.Collections.Generic.IDictionary<string, obj> * byte[] -> Orleans.Streaming.EventHubs.EventHubMessage
Public Sub New (streamId As StreamId, 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

streamId
StreamId

Stream Identity

partitionKey
String

EventHub partition key for message

offset
String

Offset into the EventHub partition where this message was from

sequenceNumber
Int64

Offset into the EventHub partition 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 object

Applies to