Compartilhar via


EventHubMessage Construtores

Definição

Sobrecargas

EventHubMessage(CachedMessage, SerializationManager)

Duplicar da classe EventData do EventHub.

EventHubMessage(CachedEventHubMessage, SerializationManager)

Duplicar da classe EventData do EventHub.

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

Contrutor

EventHubMessage(CachedMessage, SerializationManager)

Origem:
EventHubMessage.cs

Duplicar da classe EventData do EventHub.

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)

Parâmetros

cachedMessage
CachedMessage
serializationManager
SerializationManager

Aplica-se a

EventHubMessage(CachedEventHubMessage, SerializationManager)

Duplicar da classe EventData do EventHub.

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)

Parâmetros

cachedMessage
CachedEventHubMessage
serializationManager
SerializationManager

Aplica-se a

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

Origem:
EventHubMessage.cs

Contrutor

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

Parâmetros

streamIdentity
IStreamIdentity

Identidade de fluxo

partitionKey
String

Chave de partição do EventHub para mensagem

offset
String

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

sequenceNumber
Int64

Deslocamento para a pariçã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 de EventData objbect

Aplica-se a