Compartir a través de


EventGridReceiverClient class

Cliente de espacios de nombres de Event Grid

Constructores

EventGridReceiverClient(string, AzureKeyCredential | TokenCredential, string, string, EventGridReceiverClientOptions)

Cliente eventGrid de mensajería de Azure

Métodos

acknowledgeEvents(string[], AcknowledgeEventsOptions)

Confirme el lote de eventos en la nube. El servidor responde con un código de estado HTTP 200 si se confirma correctamente al menos un evento. El cuerpo de la respuesta incluirá el conjunto de lockTokens confirmados correctamente, junto con otros lockTokens con errores con su información de error correspondiente. Los eventos confirmados correctamente ya no estarán disponibles para ningún consumidor.

receiveEvents<T>(ReceiveEventsOptions)

Reciba batch of Cloud Events de la suscripción de eventos.

rejectEvents(string[], RejectEventsOptions)

Rechazar el lote de eventos en la nube.

releaseEvents(string[], ReleaseEventsOptions)

Lanzamiento por lotes de Eventos en la nube. El servidor responde con un código de estado HTTP 200 si se libera correctamente al menos un evento. El cuerpo de la respuesta incluirá el conjunto de lockTokens liberados correctamente, junto con otros lockTokens con errores con su información de error correspondiente.

renewEventLocks(string[], RenewEventLocksOptions)

Renueve el bloqueo para el lote de Eventos en la nube.

Detalles del constructor

EventGridReceiverClient(string, AzureKeyCredential | TokenCredential, string, string, EventGridReceiverClientOptions)

Cliente eventGrid de mensajería de Azure

new EventGridReceiverClient(endpoint: string, credential: AzureKeyCredential | TokenCredential, topicName: string, subscriptionName: string, options?: EventGridReceiverClientOptions)

Parámetros

endpoint

string

topicName

string

subscriptionName

string

Detalles del método

acknowledgeEvents(string[], AcknowledgeEventsOptions)

Confirme el lote de eventos en la nube. El servidor responde con un código de estado HTTP 200 si se confirma correctamente al menos un evento. El cuerpo de la respuesta incluirá el conjunto de lockTokens confirmados correctamente, junto con otros lockTokens con errores con su información de error correspondiente. Los eventos confirmados correctamente ya no estarán disponibles para ningún consumidor.

function acknowledgeEvents(lockTokens: string[], options?: AcknowledgeEventsOptions): Promise<AcknowledgeResult>

Parámetros

lockTokens

string[]

Tokens de bloqueo

options
AcknowledgeEventsOptions

Opciones para confirmar

Devoluciones

receiveEvents<T>(ReceiveEventsOptions)

Reciba batch of Cloud Events de la suscripción de eventos.

function receiveEvents<T>(options?: ReceiveEventsOptions): Promise<ReceiveResult<T>>

Parámetros

options
ReceiveEventsOptions

Opciones para recibir

Devoluciones

Promise<ReceiveResult<T>>

rejectEvents(string[], RejectEventsOptions)

Rechazar el lote de eventos en la nube.

function rejectEvents(lockTokens: string[], options?: RejectEventsOptions): Promise<RejectResult>

Parámetros

lockTokens

string[]

Tokens de bloqueo

options
RejectEventsOptions

Opciones para rechazar

Devoluciones

Promise<RejectResult>

releaseEvents(string[], ReleaseEventsOptions)

Lanzamiento por lotes de Eventos en la nube. El servidor responde con un código de estado HTTP 200 si se libera correctamente al menos un evento. El cuerpo de la respuesta incluirá el conjunto de lockTokens liberados correctamente, junto con otros lockTokens con errores con su información de error correspondiente.

function releaseEvents(lockTokens: string[], options?: ReleaseEventsOptions): Promise<ReleaseResult>

Parámetros

lockTokens

string[]

Tokens de bloqueo

options
ReleaseEventsOptions

Opciones para liberar

Devoluciones

Promise<ReleaseResult>

renewEventLocks(string[], RenewEventLocksOptions)

Renueve el bloqueo para el lote de Eventos en la nube.

function renewEventLocks(lockTokens: string[], options?: RenewEventLocksOptions): Promise<RenewLocksResult>

Parámetros

lockTokens

string[]

Tokens de bloqueo

options
RenewEventLocksOptions

Opciones para renovar

Devoluciones

Promise<RenewLocksResult>