Class AmqpService

constructor

• new AmqpService(): AmqpService

  Returns AmqpService

Readonlyinitialized

ReadonlyisReady

ack

• ack(message: Message, allToUp?: boolean): void

  Parameters

  • message: Message
  • OptionalallToUp: boolean

  Returns void

addHandler

• addHandler(routingKey: string, handler: MessageHandler): Promise<void>

  Parameters

  • routingKey: string
  • handler: MessageHandler

  Returns Promise<void>

bind

• bind(pattern: string): Promise<void>

  Parameters

  • pattern: string

  Returns Promise<void>

emit

• emit(routingKey: string, data: any, options?: PublishOptions): Promise<void>

  Parameters

  • routingKey: string
  • data: any
  • options: PublishOptions = {}

  Returns Promise<void>

init

• init(): Promise<void>

  Returns Promise<void>

nack

• nack(message: Message, allToUp?: boolean, requeue?: boolean): void

  Parameters

  • message: Message
  • OptionalallToUp: boolean
  • Optionalrequeue: boolean

  Returns void

onApplicationBootstrap

• onApplicationBootstrap(): Promise<void>

  Returns Promise<void>

replay

• replay(replayQueue: string, data: any, options?: PublishOptions): Promise<void>

  Parameters

  • replayQueue: string
  • data: any
  • options: PublishOptions = {}

  Returns Promise<void>

send

• send<T>(routingKey: string, data: any, options?: PublishOptions): Promise<T>

  Type Parameters

  • T

  Parameters

  • routingKey: string
  • data: any
  • options: PublishOptions = {}

  Returns Promise<T>

unbind

• unbind(pattern: string): Promise<void>

  Parameters

  • pattern: string

  Returns Promise<void>