Aller au contenu principal
Version: Next

IRabbitMQApplication

Index

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>