IRabbitMQApplication

Index

Methods

• close
• connect
• createChannel
• createConsumer

Methods

close

• close(): Promise<void>

connect

• connect(...args: any[]): Promise<void>

createChannel

• createChannel(): Promise<Channel | ConfirmChannel>

createConsumer

• createConsumer(listenerOptions: RabbitMQListenerOptions, listenerCallback: (msg: ConsumeMessage, channel: Channel, channelWrapper: any) => Promise<void>): Promise<void>