Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ClusteredRedisQueue

Class ClusteredRedisQueue Implements possibility to scale queues horizontally between several redis instances.

Hierarchy

  • ClusteredRedisQueue

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

logger

logger: ILogger

Logger instance associated with this queue instance

type

{ILogger}

name

name: string

Methods

addListener

  • addListener(...args: any[]): this

clear

destroy

  • destroy(): Promise<void>

emit

  • emit(...args: any[]): boolean

eventNames

  • eventNames(...args: any[]): any

getMaxListeners

  • getMaxListeners(): number

listenerCount

  • listenerCount(...args: any[]): any

listeners

  • listeners(...args: any[]): any[]

off

  • off(...args: any[]): this

on

  • on(...args: any[]): this

once

  • once(...args: any[]): this

prependListener

  • prependListener(...args: any[]): this

prependOnceListener

  • prependOnceListener(...args: any[]): this

rawListeners

  • rawListeners(...args: any[]): any[]

removeAllListeners

  • removeAllListeners(...args: any[]): this

removeListener

  • removeListener(...args: any[]): this

send

  • send(toQueue: string, message: IJson, delay?: undefined | number, errorHandler?: undefined | function): Promise<string>

  • Sends a message to given queue name with the given data. Supposed to be an async function.

    Parameters

    • toQueue: string

      queue name to which message should be sent to

    • message: IJson

      message data

    • Optional delay: undefined | number
    • Optional errorHandler: undefined | function

    Returns Promise<string>

    • message identifier

setMaxListeners

  • setMaxListeners(...args: any[]): this

start

stop