EventHubMessage Construtores

Definição

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Pacote:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Sobrecargas

EventHubMessage(CachedMessage, Serializer)	Duplicar da classe EventData do EventHub.
EventHubMessage(StreamId, String, String, Int64, DateTime, DateTime, IDictionary<String,Object>, Byte[])	Construtor

EventHubMessage(CachedMessage, Serializer)

Duplicar da classe EventData do 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)

Parâmetros

cachedMessage

CachedMessage

serializer

Serializer

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

Construtor

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

Parâmetros

streamId

StreamId

Identidade de fluxo

partitionKey

String

Chave de partição do EventHub para mensagem

offset

String

Deslocamento para a partição do EventHub de onde esta mensagem era

sequenceNumber

Int64

Deslocamento para a partição do EventHub de onde esta mensagem era

enqueueTimeUtc

DateTime

Hora em UTC em que essa mensagem foi injetada pelo EventHub

dequeueTimeUtc

DateTime

Hora em UTC em que esta mensagem foi lida do EventHub para o serviço atual

properties

IDictionary<String,Object>

Propriedades do usuário do objeto EventData

payload

Byte[]

Dados binários do objeto EventData