EventHubMessage Constructors
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Overloads
EventHubMessage(CachedMessage, Serializer) |
Duplicate of EventHub's EventData class. |
EventHubMessage(StreamId, String, String, Int64, DateTime, DateTime, IDictionary<String,Object>, Byte[]) |
Constructor |
EventHubMessage(CachedMessage, Serializer)
Duplicate of EventHub's EventData class.
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)
Parameters
- cachedMessage
- CachedMessage
- serializer
- Serializer
Applies to
EventHubMessage(StreamId, String, String, Int64, DateTime, DateTime, IDictionary<String,Object>, Byte[])
Constructor
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())
Parameters
- streamId
- StreamId
Stream Identity
- partitionKey
- String
EventHub partition key for message
- offset
- String
Offset into the EventHub partition where this message was from
- sequenceNumber
- Int64
Offset into the EventHub partition where this message was from
- enqueueTimeUtc
- DateTime
Time in UTC when this message was injected by EventHub
- dequeueTimeUtc
- DateTime
Time in UTC when this message was read from EventHub into the current service
- properties
- IDictionary<String,Object>
User properties from EventData object
- payload
- Byte[]
Binary data from EventData object