ReceivedEventData interface
Die Schnittstelle, die die Struktur des Ereignisses beschreibt, das vom Event Hub empfangen wurde.
Verwenden Sie dies als Verweis beim Erstellen der processEvents
-Funktion, um die ereignisse zu verarbeiten, die von einem Event Hub bei Verwendung der EventHubConsumerClient
empfangen werden.
Eigenschaften
body | Der Nachrichtentext, der gesendet oder empfangen werden muss. |
content |
Der Inhaltstyp der Nachricht. Beschreibt optional die Nutzlast der Nachricht, wobei ein Deskriptor nach dem Format von RFC2045, Abschnitt 5, z. B. "application/json", folgt. |
correlation |
Der Korrelationsbezeichner, der es einer Anwendung ermöglicht, einen Kontext für die Nachricht für die Zwecke der Korrelation anzugeben, z. B. die MessageId einer Nachricht, auf die geantwortet wird. |
enqueued |
Die queuierte Zeit des Ereignisses. |
message |
Der Nachrichtenbezeichner ist ein anwendungsdefinierter Wert, der die Nachricht und deren Nutzlast eindeutig identifiziert. |
offset | Der Offset des Ereignisses. |
partition |
Wenn der Event Hub angegeben wird, wird dies auf eine partitionId hashen. Es garantiert, dass Nachrichten in einer bestimmten Partition auf dem Event Hub enden. |
properties | Die anwendungsspezifischen Eigenschaften. |
sequence |
Die Sequenznummer des Ereignisses. |
system |
Die vom Dienst festgelegten Eigenschaften. |
Methoden
get |
Gibt die zugrunde liegende unformatierte Amqp-Nachricht zurück. |
Details zur Eigenschaft
body
Der Nachrichtentext, der gesendet oder empfangen werden muss.
body: any
Eigenschaftswert
any
contentType
Der Inhaltstyp der Nachricht. Beschreibt optional die Nutzlast der Nachricht, wobei ein Deskriptor nach dem Format von RFC2045, Abschnitt 5, z. B. "application/json", folgt.
contentType?: string
Eigenschaftswert
string
correlationId
Der Korrelationsbezeichner, der es einer Anwendung ermöglicht, einen Kontext für die Nachricht für die Zwecke der Korrelation anzugeben, z. B. die MessageId einer Nachricht, auf die geantwortet wird.
correlationId?: string | number | Buffer
Eigenschaftswert
string | number | Buffer
enqueuedTimeUtc
Die queuierte Zeit des Ereignisses.
enqueuedTimeUtc: Date
Eigenschaftswert
Date
messageId
Der Nachrichtenbezeichner ist ein anwendungsdefinierter Wert, der die Nachricht und deren Nutzlast eindeutig identifiziert.
messageId?: string | number | Buffer
Eigenschaftswert
string | number | Buffer
offset
Der Offset des Ereignisses.
offset: number
Eigenschaftswert
number
partitionKey
Wenn der Event Hub angegeben wird, wird dies auf eine partitionId hashen. Es garantiert, dass Nachrichten in einer bestimmten Partition auf dem Event Hub enden.
partitionKey: null | string
Eigenschaftswert
null | string
properties
Die anwendungsspezifischen Eigenschaften.
properties?: {[key: string]: any}
Eigenschaftswert
{[key: string]: any}
sequenceNumber
Die Sequenznummer des Ereignisses.
sequenceNumber: number
Eigenschaftswert
number
systemProperties
Die vom Dienst festgelegten Eigenschaften.
systemProperties?: {[key: string]: any}
Eigenschaftswert
{[key: string]: any}
Details zur Methode
getRawAmqpMessage()
Gibt die zugrunde liegende unformatierte Amqp-Nachricht zurück.
function getRawAmqpMessage(): AmqpAnnotatedMessage