Options
All
  • Public
  • Public/Protected
  • All
Menu

Class Queue<T>

AbstractQueue implements the worker system

A Worker allows you to define how to process message from the queue, implementing the retries policy

Type parameters

Hierarchy

Constructors

  • new Queue(webda: Core, name: string, params?: any): Queue

Properties

_createException: string
_initException: any = undefined
_initTime: number
_interrupt: boolean
_name: string

Service name

_timeout: any
_webda: Core

Webda Core object

callback: Function
logger: Logger

Logger with class context

parameters: T

Hold the parameters for your service

It will be bring from the webda.config.json

pause: number
defaultMaxListeners: number

Methods

  • __clean(): Promise<any>
  • _workerReceiveMessage(): Promise<void>
  • _workerResume(): Promise<void>
  • addListener(event: string | symbol, listener: function): this
  • addRoute(url: string, methods: HttpMethodType[], executer: Function, openapi?: object, allowPath?: boolean): void
  • computeParameters(): void
  • deleteMessage(id: string): Promise<void>
  • emit(event: string | symbol, ...args: any[]): boolean
  • emitSync(event: any, data: any): Promise<any[]>
  • eventNames(): Array<string | symbol>
  • getMaxListeners(): number
  • getName(): string
  • getParameters(): T
  • getService<T>(service: string): T
  • init(): Promise<void>
  • initRoutes(): void
  • listenerCount(type: string | symbol): number
  • listeners(event: string | symbol): Function[]
  • off(event: string | symbol, listener: function): this
  • on(event: string | symbol, listener: function): this
  • onAsync(event: any, callback: any, queue?: string): void
  • Listen to an event as on(...) would do except that it will be asynchronous

    Parameters

    • event: any
    • callback: any
    • Default value queue: string = undefined

      Name of queue to use, can be undefined, queue name are used to define differents priorities

    Returns void

  • once(event: string | symbol, listener: function): this
  • prependListener(event: string | symbol, listener: function): this
  • prependOnceListener(event: string | symbol, listener: function): this
  • rawListeners(event: string | symbol): Function[]
  • receiveMessage(): Promise<any>
  • reinit(config: any): Promise<void>
  • removeAllListeners(event?: string | symbol): this
  • removeListener(event: string | symbol, listener: function): this
  • resolve(): void
  • sendMessage(params: any): Promise<void>
  • setMaxListeners(n: number): this
  • size(): Promise<number>
  • stop(): void
  • toPublicJSON(object: any): string
  • worker(callback: any): Promise<void>
  • listenerCount(emitter: EventEmitter, event: string | symbol): number

Generated using TypeDoc