Class ChannelWrapper<ChannelType>

Wrapper for amqplib Channel

Type parameters

ChannelType: Channel

Hierarchy

EventEmitter
- ChannelWrapper

Index

Methods

Methods

close

close(): Promise<void>

Stop wrapper and close channel

Returns Promise<void>

getChannel

getChannel(): Promise<null | ChannelType>

Get amqplib Channel (or ConfirmChannel). Returns null if channel was closed with error or manually

Returns Promise<null | ChannelType>

getChannelSync

getChannelSync(): null | ChannelType

Returns channel if it is currently open, otherwise null

Returns null | ChannelType

on

on<E>(event: E, listener: IChannelWrapperEvents<ChannelType>[E]): ChannelWrapper<ChannelType>

Events are documented here

Type parameters
- E: keyof IChannelWrapperEvents<ChannelType>
Parameters
- event: E
- listener: IChannelWrapperEvents<ChannelType>[E]
Returns ChannelWrapper<ChannelType>

reset

reset(): Promise<void>

Close channel and open a new one

Returns Promise<void>

Generated using TypeDoc