Class Consumer

Hierarchy

Consumer

Index

Constructors

Methods

acknowledge acknowledgeCumulative acknowledgeCumulativeId acknowledgeId close isConnected negativeAcknowledge negativeAcknowledgeId receive seek seekTimestamp unsubscribe

Constructors

constructor

new Consumer(): Consumer
Returns Consumer

Methods

acknowledge

acknowledge(message: Message): Promise<null>
Parameters
- message: Message
Returns Promise<null>
- Defined in index.d.ts:98

acknowledgeCumulative

acknowledgeCumulative(message: Message): Promise<null>
Parameters
- message: Message
Returns Promise<null>
- Defined in index.d.ts:102

acknowledgeCumulativeId

acknowledgeCumulativeId(messageId: MessageId): Promise<null>
Parameters
- messageId: MessageId
Returns Promise<null>
- Defined in index.d.ts:103

acknowledgeId

acknowledgeId(messageId: MessageId): Promise<null>
Parameters
- messageId: MessageId
Returns Promise<null>
- Defined in index.d.ts:99

close

close(): Promise<null>
Returns Promise<null>
- Defined in index.d.ts:107

isConnected

isConnected(): boolean
Returns boolean
- Defined in index.d.ts:106

negativeAcknowledge

negativeAcknowledge(message: Message): void
Parameters
- message: Message
Returns void
- Defined in index.d.ts:100

negativeAcknowledgeId

negativeAcknowledgeId(messageId: MessageId): void
Parameters
- messageId: MessageId
Returns void
- Defined in index.d.ts:101

receive

receive(timeout?: number): Promise<Message>
Parameters
- Optional timeout: number
Returns Promise<Message>
- Defined in index.d.ts:97

seek

seek(messageId: MessageId): Promise<null>
Parameters
- messageId: MessageId
Returns Promise<null>
- Defined in index.d.ts:104

seekTimestamp

seekTimestamp(timestamp: number): Promise<null>
Parameters
- timestamp: number
Returns Promise<null>
- Defined in index.d.ts:105

unsubscribe

unsubscribe(): Promise<null>
Returns Promise<null>
- Defined in index.d.ts:108

Generated using TypeDoc