Skip to main content

@webda/amqpReadme | API


Class: AMQPQueueParameters

Extends

  • QueueParameters

Constructors

new AMQPQueueParameters(params)

new AMQPQueueParameters(params): AMQPQueueParameters

Parameters

params: any

Returns

AMQPQueueParameters

Inherited from

QueueParameters.constructor

Inherit Doc

Source

core/lib/queues/queueservice.d.ts:42

Properties

maxConsumers

maxConsumers: number

Max number of queue consumers Queue will auto increase to this max number if queue is loaded and it will decrease to just one consumer if no messages are available

Default

10

Inherited from

QueueParameters.maxConsumers

Source

core/lib/queues/queueservice.d.ts:38


openapi?

openapi?: OpenAPIWebdaDefinition

OpenAPI override

Schema Ignore

Inherited from

QueueParameters.openapi

Source

core/lib/services/service.d.ts:104


queue

queue: string

Source

amqp/src/queue.ts:6


queueOptions?

queueOptions?: any

Source

amqp/src/queue.ts:7


type

type: string

Type of the service

Inherited from

QueueParameters.type

Source

core/lib/services/service.d.ts:95


url

url: string

Overrides

QueueParameters.url

Source

amqp/src/queue.ts:5


workerDelayer?

workerDelayer?: WaitDelayerDefinition

Delayer between two failed attempts to process messages

Inherited from

QueueParameters.workerDelayer

Source

core/lib/queues/queueservice.d.ts:25


workerParallelism?

workerParallelism?: boolean

Define if worker should process multi message received in //

Default

true

Inherited from

QueueParameters.workerParallelism

Source

core/lib/queues/queueservice.d.ts:30