EventHubMessage Costruttori

Definizione

Spazio dei nomi:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Pacchetto:

Microsoft.Orleans.Streaming.EventHubs v9.0.0

Overload

EventHubMessage(CachedMessage, Serializer)	Duplicato della classe EventData di EventHub.
EventHubMessage(StreamId, String, String, Int64, DateTime, DateTime, IDictionary<String,Object>, Byte[])	Costruttore

EventHubMessage(CachedMessage, Serializer)

Duplicato della classe EventData di EventHub.

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)

Parametri

cachedMessage

CachedMessage

serializer

Serializer

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

Costruttore

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())

Parametri

streamId

StreamId

Identità di flusso

partitionKey

String

Chiave di partizione eventHub per il messaggio

offset

String

Offset nella partizione EventHub da cui proviene questo messaggio

sequenceNumber

Int64

Offset nella partizione EventHub da cui proviene questo messaggio

enqueueTimeUtc

DateTime

Ora UTC quando questo messaggio è stato inserito da EventHub

dequeueTimeUtc

DateTime

Ora UTC quando questo messaggio è stato letto da EventHub nel servizio corrente

properties

IDictionary<String,Object>

Proprietà utente dall'oggetto EventData

payload

Byte[]

Dati binari dall'oggetto EventData