Skip to main content

AMQPQueueParameters

@webda/amqp

Class: AMQPQueueParameters

Defined in: amqp/src/queue.service.ts:8

Configuration for AMQPQueue

Extends​

  • QueueParameters

Constructors​

Constructor​

new AMQPQueueParameters(): AMQPQueueParameters

Returns​

AMQPQueueParameters

Inherited from​

QueueParameters.constructor

Properties​

maxConsumers​

maxConsumers: number

Defined in: core/lib/queues/queueservice.d.ts:37

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

queue​

queue: string

Defined in: amqp/src/queue.service.ts:17

Queue name

queueOptions?​

optional queueOptions?: any

Defined in: amqp/src/queue.service.ts:21

Options passed to assertQueue

type​

type: string

Defined in: core/lib/services/serviceparameters.d.ts:8

Type of the service

Inherited from​

QueueParameters.type

url​

url: string

Defined in: amqp/src/queue.service.ts:13

AMQP connection url

Example​

"amqp://localhost:5672"

workerDelayer?​

optional workerDelayer?: WaitDelayerDefinition

Defined in: core/lib/queues/queueservice.d.ts:24

Delayer between two failed attempts to process messages

Inherited from​

QueueParameters.workerDelayer

workerParallelism​

workerParallelism: boolean

Defined in: core/lib/queues/queueservice.d.ts:29

Define if worker should process multi message received in //

Default​

true

Inherited from​

QueueParameters.workerParallelism

Methods​

load()​

load(params?): this

Defined in: core/lib/services/serviceparameters.d.ts:18

Load raw parameters by assigning them onto this instance

Parameters​

params?​

any

the service parameters

Returns​

this

this for chaining

Inherited from​

QueueParameters.load

update()​

update(params, delta): this

Defined in: core/lib/services/serviceparameters.d.ts:25

Update parameters and call watchers if a parameter was changed

Parameters​

params​

any

the service parameters

delta​

any

the delta

Returns​

this

this for chaining

Inherited from​

QueueParameters.update

with()​

with(callback): this

Defined in: core/lib/services/serviceparameters.d.ts:31

Watch for changes on the parameters and call watchers when a parameter is changed

Parameters​

callback​

(params) => void

the callback function

Returns​

this

this for chaining

Inherited from​

QueueParameters.with