Condividi tramite


EventHubMessage Costruttori

Definizione

Overload

EventHubMessage(CachedMessage, SerializationManager)

Duplicato della classe EventData di EventHub.

EventHubMessage(CachedEventHubMessage, SerializationManager)

Duplicato della classe EventData di EventHub.

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

Contructor

EventHubMessage(CachedMessage, SerializationManager)

Origine:
EventHubMessage.cs

Duplicato della classe EventData di 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)

Parametri

cachedMessage
CachedMessage
serializationManager
SerializationManager

Si applica a

EventHubMessage(CachedEventHubMessage, SerializationManager)

Duplicato della classe EventData di 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)

Parametri

cachedMessage
CachedEventHubMessage
serializationManager
SerializationManager

Si applica a

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

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

Parametri

streamIdentity
IStreamIdentity

Identità di flusso

partitionKey
String

Chiave di partizione eventHub per il messaggio

offset
String

Offset nella parition eventHub da cui è stato eseguito questo messaggio

sequenceNumber
Int64

Offset nella parition eventHub da cui è stato eseguito 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 da EventData objbect

Si applica a