EventHubMessage 构造函数

定义

命名空间:

Orleans.ServiceBus.Providers

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.OrleansServiceBus v3.6.5

重载

EventHubMessage(CachedMessage, SerializationManager)	EventHub 的 EventData 类的副本。
EventHubMessage(IStreamIdentity, String, String, Int64, DateTime, DateTime, IDictionary<String,Object>, Byte[])	构造函数

EventHubMessage(CachedMessage, SerializationManager)

Source:

EventHubMessage.cs

EventHub 的 EventData 类的副本。

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)

参数

cachedMessage

CachedMessage

serializationManager

SerializationManager

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

Source:

EventHubMessage.cs

构造函数

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

参数

streamIdentity

IStreamIdentity

流标识

partitionKey

String

消息的 EventHub 分区键

offset

String

此消息来自的 EventHub 分析的偏移量

sequenceNumber

Int64

此消息来自的 EventHub 分析的偏移量

enqueueTimeUtc

DateTime

EventHub 注入此消息的时间（UTC 时间）

dequeueTimeUtc

DateTime

此消息从 EventHub 读取到当前服务的时间（UTC）

properties

IDictionary<String,Object>

EventData 对象的用户属性

payload

Byte[]

EventData objbect 中的二进制数据