Udostępnij za pośrednictwem

ReceivedEventData interface

  • Odwołanie
Pakiet:
@azure/event-hubs

Interfejs opisujący strukturę zdarzenia odebranego z centrum zdarzeń. Użyj tej funkcji jako odwołania podczas tworzenia funkcji processEvents do przetwarzania zdarzeń odebranych z centrum zdarzeń podczas korzystania z EventHubConsumerClient.

Właściwości

body

Treść wiadomości, która musi zostać wysłana lub odebrana.
contentType

Typ zawartości wiadomości. Opcjonalnie opisuje ładunek komunikatu z deskryptorem w formacie RFC2045, sekcja 5, na przykład "application/json".
correlationId

Identyfikator korelacji, który umożliwia aplikacji określenie kontekstu komunikatu na potrzeby korelacji, na przykład odzwierciedlające identyfikator MessageId komunikatu, do którego jest odpowiadana.
enqueuedTimeUtc

Czas w kolejce zdarzenia.
messageId

Identyfikator komunikatu jest wartością zdefiniowaną przez aplikację, która jednoznacznie identyfikuje komunikat i jego ładunek.
offset

Przesunięcie zdarzenia.
partitionKey

Po określeniu centrum zdarzeń zostanie skrót do identyfikatora partitionId. Gwarantuje to, że komunikaty trafią do określonej partycji w centrum zdarzeń.
properties

Właściwości specyficzne dla aplikacji.
sequenceNumber

Numer sekwencji zdarzenia.
systemProperties

Właściwości ustawione przez usługę.

Metody

getRawAmqpMessage()

Zwraca podstawowy nieprzetworzona wiadomość amqp.

Szczegóły właściwości

body

Treść wiadomości, która musi zostać wysłana lub odebrana.

body: any

Wartość właściwości

any

contentType

Typ zawartości wiadomości. Opcjonalnie opisuje ładunek komunikatu z deskryptorem w formacie RFC2045, sekcja 5, na przykład "application/json".

contentType?: string

Wartość właściwości

string

correlationId

Identyfikator korelacji, który umożliwia aplikacji określenie kontekstu komunikatu na potrzeby korelacji, na przykład odzwierciedlające identyfikator MessageId komunikatu, do którego jest odpowiadana.

correlationId?: string | number | Buffer

Wartość właściwości

string | number | Buffer

enqueuedTimeUtc

Czas w kolejce zdarzenia.

enqueuedTimeUtc: Date

Wartość właściwości

Date

messageId

Identyfikator komunikatu jest wartością zdefiniowaną przez aplikację, która jednoznacznie identyfikuje komunikat i jego ładunek.

messageId?: string | number | Buffer

Wartość właściwości

string | number | Buffer

offset

Przesunięcie zdarzenia.

offset: number

Wartość właściwości

number

partitionKey

Po określeniu centrum zdarzeń zostanie skrót do identyfikatora partitionId. Gwarantuje to, że komunikaty trafią do określonej partycji w centrum zdarzeń.

partitionKey: null | string

Wartość właściwości

null | string

properties

Właściwości specyficzne dla aplikacji.

properties?: {[key: string]: any}

Wartość właściwości

{[key: string]: any}

sequenceNumber

Numer sekwencji zdarzenia.

sequenceNumber: number

Wartość właściwości

number

systemProperties

Właściwości ustawione przez usługę.

systemProperties?: {[key: string]: any}

Wartość właściwości

{[key: string]: any}

Szczegóły metody

getRawAmqpMessage()

Zwraca podstawowy nieprzetworzona wiadomość amqp.

function getRawAmqpMessage(): AmqpAnnotatedMessage

Zwraca

AmqpAnnotatedMessage