Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface IRabbitMQApplication

Hierarchy

  • IRabbitMQApplication

Implemented by

Methods

assertQueue

  • assertQueue(queue: string, options?: any): Promise<void>

close

  • close(): Promise<void>

closeChannel

  • closeChannel(): Promise<void>

connect

  • connect(): Promise<void>

createChannel

  • createChannel(): Promise<void>

createConsumer

  • createConsumer(listenerOptions: RabbitMQListenerOptions, listenerCallback: function): Promise<void>
  • Parameters

    • listenerOptions: RabbitMQListenerOptions
    • listenerCallback: function
        • (msg: ConsumeMessage | null): Promise<void>
        • Parameters

          • msg: ConsumeMessage | null

          Returns Promise<void>

    Returns Promise<void>

getChannel

  • getChannel(): Channel

init

  • init(): Promise<void>

Generated using TypeDoc