Options
All
  • Public
  • Public/Protected
  • All
Menu

Hierarchy

Index

Methods

ack

  • ack(message: Message, allUpTo?: boolean): void
  • Parameters

    • message: Message
    • Optional allUpTo: boolean

    Returns void

ackAll

  • ackAll(): void
  • Returns void

addListener

  • addListener(event: string | symbol, listener: (...args: any[]) => void): Channel
  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns Channel

assertExchange

  • Parameters

    Returns Bluebird<AssertExchange>

assertQueue

  • Parameters

    Returns Bluebird<AssertQueue>

bindExchange

  • bindExchange(destination: string, source: string, pattern: string, args?: any): Bluebird<Empty>
  • Parameters

    • destination: string
    • source: string
    • pattern: string
    • Optional args: any

    Returns Bluebird<Empty>

bindQueue

  • bindQueue(queue: string, source: string, pattern: string, args?: any): Bluebird<Empty>
  • Parameters

    • queue: string
    • source: string
    • pattern: string
    • Optional args: any

    Returns Bluebird<Empty>

cancel

  • cancel(consumerTag: string): Bluebird<Empty>
  • Parameters

    • consumerTag: string

    Returns Bluebird<Empty>

checkExchange

  • checkExchange(exchange: string): Bluebird<Empty>
  • Parameters

    • exchange: string

    Returns Bluebird<Empty>

checkQueue

  • Parameters

    • queue: string

    Returns Bluebird<AssertQueue>

close

  • close(): Bluebird<void>
  • Returns Bluebird<void>

consume

deleteExchange

  • Parameters

    Returns Bluebird<Empty>

deleteQueue

  • Parameters

    Returns Bluebird<DeleteQueue>

emit

  • emit(event: string | symbol, ...args: any[]): boolean
  • Parameters

    • event: string | symbol
    • Rest ...args: any[]

    Returns boolean

eventNames

  • eventNames(): (string | symbol)[]
  • Returns (string | symbol)[]

get

  • get(queue: string, options?: Get): Bluebird<false | GetMessage>
  • Parameters

    • queue: string
    • Optional options: Get

    Returns Bluebird<false | GetMessage>

getMaxListeners

  • getMaxListeners(): number
  • Returns number

listenerCount

  • listenerCount(event: string | symbol): number
  • Parameters

    • event: string | symbol

    Returns number

listeners

  • listeners(event: string | symbol): Function[]
  • Parameters

    • event: string | symbol

    Returns Function[]

nack

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

    • message: Message
    • Optional allUpTo: boolean
    • Optional requeue: boolean

    Returns void

nackAll

  • nackAll(requeue?: boolean): void
  • Parameters

    • Optional requeue: boolean

    Returns void

off

  • off(event: string | symbol, listener: (...args: any[]) => void): Channel
  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns Channel

on

  • on(event: string | symbol, listener: (...args: any[]) => void): Channel
  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns Channel

once

  • once(event: string | symbol, listener: (...args: any[]) => void): Channel
  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns Channel

prefetch

  • prefetch(count: number, global?: boolean): Bluebird<Empty>
  • Parameters

    • count: number
    • Optional global: boolean

    Returns Bluebird<Empty>

prependListener

  • prependListener(event: string | symbol, listener: (...args: any[]) => void): Channel
  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns Channel

prependOnceListener

  • prependOnceListener(event: string | symbol, listener: (...args: any[]) => void): Channel
  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns Channel

publish

  • publish(exchange: string, routingKey: string, content: Buffer, options?: Publish): boolean
  • Parameters

    • exchange: string
    • routingKey: string
    • content: Buffer
    • Optional options: Publish

    Returns boolean

purgeQueue

  • Parameters

    • queue: string

    Returns Bluebird<PurgeQueue>

rawListeners

  • rawListeners(event: string | symbol): Function[]
  • Parameters

    • event: string | symbol

    Returns Function[]

recover

  • recover(): Bluebird<Empty>
  • Returns Bluebird<Empty>

reject

  • reject(message: Message, requeue?: boolean): void
  • Parameters

    • message: Message
    • Optional requeue: boolean

    Returns void

removeAllListeners

  • removeAllListeners(event?: string | symbol): Channel
  • Parameters

    • Optional event: string | symbol

    Returns Channel

removeListener

  • removeListener(event: string | symbol, listener: (...args: any[]) => void): Channel
  • Parameters

    • event: string | symbol
    • listener: (...args: any[]) => void
        • (...args: any[]): void
        • Parameters

          • Rest ...args: any[]

          Returns void

    Returns Channel

sendToQueue

  • sendToQueue(queue: string, content: Buffer, options?: Publish): boolean
  • Parameters

    • queue: string
    • content: Buffer
    • Optional options: Publish

    Returns boolean

setMaxListeners

  • setMaxListeners(n: number): Channel
  • Parameters

    • n: number

    Returns Channel

unbindExchange

  • unbindExchange(destination: string, source: string, pattern: string, args?: any): Bluebird<Empty>
  • Parameters

    • destination: string
    • source: string
    • pattern: string
    • Optional args: any

    Returns Bluebird<Empty>

unbindQueue

  • unbindQueue(queue: string, source: string, pattern: string, args?: any): Bluebird<Empty>
  • Parameters

    • queue: string
    • source: string
    • pattern: string
    • Optional args: any

    Returns Bluebird<Empty>

Generated using TypeDoc