ReceivedEventData interface
Die Schnittstelle, die die Struktur des von Event Hub empfangenen Ereignisses beschreibt.
Verwenden Sie dies als Verweis beim Erstellen der processEvents
-Funktion, um die Ereignisse zu verarbeiten, die von einem Event Hub empfangen werden, wenn Sie verwenden EventHubConsumerClient
.
Eigenschaften
body | Der Nachrichtentext, der gesendet oder empfangen werden muss. |
content |
Der Inhaltstyp der Nachricht. Beschreibt optional die Nutzlast der Nachricht, wobei ein Deskriptor dem Format RFC2045, Abschnitt 5 folgt, z. B. "application/json". |
correlation |
Der Korrelationsbezeichner, mit dem eine Anwendung einen Kontext für die Nachricht zum Zweck der Korrelation angeben kann, z. B. die MessageId einer Nachricht, auf die geantwortet wird. |
enqueued |
Der in die Warteschlange eingereihte Zeitpunkt des Ereignisses.The enqueued time of the enqueued time of the event. |
message |
Der Nachrichtenbezeichner ist ein von der Anwendung definierter Wert, der die Nachricht und ihre Nutzlast eindeutig identifiziert. |
offset | Der Offset des Ereignisses. |
partition |
Bei Angabe von Event Hub wird dies in eine partitionId gehasht. Dadurch wird sichergestellt, dass Nachrichten in einer bestimmten Partition im 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 dem Format RFC2045, Abschnitt 5 folgt, z. B. "application/json".
contentType?: string
Eigenschaftswert
string
correlationId
Der Korrelationsbezeichner, mit dem eine Anwendung einen Kontext für die Nachricht zum Zweck der Korrelation angeben kann, z. B. die MessageId einer Nachricht, auf die geantwortet wird.
correlationId?: string | number | Buffer
Eigenschaftswert
string | number | Buffer
enqueuedTimeUtc
Der in die Warteschlange eingereihte Zeitpunkt des Ereignisses.The enqueued time of the enqueued time of the event.
enqueuedTimeUtc: Date
Eigenschaftswert
Date
messageId
Der Nachrichtenbezeichner ist ein von der Anwendung definierter Wert, der die Nachricht und ihre Nutzlast eindeutig identifiziert.
messageId?: string | number | Buffer
Eigenschaftswert
string | number | Buffer
offset
Der Offset des Ereignisses.
offset: number
Eigenschaftswert
number
partitionKey
Bei Angabe von Event Hub wird dies in eine partitionId gehasht. Dadurch wird sichergestellt, dass Nachrichten in einer bestimmten Partition im 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