Skip to main content

QueueParameters

@webda/core

Class: QueueParameters

Defined in: packages/core/src/queues/queueservice.ts:28

Interface to specify the Service parameters

Extends​

Extended by​

Constructors​

Constructor​

new QueueParameters(): QueueParameters

Returns​

QueueParameters

Inherited from​

ServiceParameters.constructor

Properties​

maxConsumers​

maxConsumers: number = 10

Defined in: packages/core/src/queues/queueservice.ts:45

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

type​

type: string

Defined in: packages/core/src/services/serviceparameters.ts:10

Type of the service

Inherited from​

ServiceParameters.type

workerDelayer?​

optional workerDelayer?: WaitDelayerDefinition

Defined in: packages/core/src/queues/queueservice.ts:32

Delayer between two failed attempts to process messages

workerParallelism​

workerParallelism: boolean = true

Defined in: packages/core/src/queues/queueservice.ts:37

Define if worker should process multi message received in //

Default​

true

Methods​

load()​

load(params?): this

Defined in: packages/core/src/services/serviceparameters.ts:24

Load raw parameters by assigning them onto this instance

Parameters​

params?​

any = {}

the service parameters

Returns​

this

this for chaining

Inherited from​

ServiceParameters.load

update()​

update(params?, delta): this

Defined in: packages/core/src/services/serviceparameters.ts:35

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​

ServiceParameters.update

with()​

with(callback): this

Defined in: packages/core/src/services/serviceparameters.ts:65

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​

ServiceParameters.with