Class VolgaConsumer

Volga consumer

Index

Constructors

Properties

onConnect? onError? onMessage?

Methods

ack close connect

Constructors

constructor

new VolgaConsumer(ws_uri, token, opts): VolgaConsumer
Internal
Invoked by Client.open_volga_consumer
Parameters
- ws_uri: string
- token: string
- opts: OpenConsumer
Returns VolgaConsumer
- Defined in volga.ts:214

Properties

`Optional`onConnect

onConnect?: VolgaConnectListener

Called back on successful connect

`Optional`onError

onError?: VolgaErrorListener

Called back on error

`Optional`onMessage

onMessage?: VolgaMessageListener

Called back on incoming volga message

Methods

ack

ack(seqno): void
Acknowledge received message
Parameters
- seqno: number
  sequence number of received message
Returns void
- Defined in volga.ts:278

close

close(): void
Close consumer

Returns void
- Defined in volga.ts:302

connect

connect(): void
Call to connect the consumer

Returns void
- Defined in volga.ts:226