Skip to main content

AMQPPubSubParameters

@webda/amqp

Class: AMQPPubSubParameters

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

Configuration for AMQPPubSubService

Extends​

  • ServiceParameters

Constructors​

Constructor​

new AMQPPubSubParameters(): AMQPPubSubParameters

Returns​

AMQPPubSubParameters

Inherited from​

ServiceParameters.constructor

Properties​

channel​

channel: string

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

Exchange name to publish to and consume from

exchange?​

optional exchange?: object

Defined in: amqp/src/pubsub.service.ts:23

alternateExchange?​

optional alternateExchange?: string

an exchange to send messages to if this exchange can’t route them to any queues.

Specific to RabbitMQ

arguments?​

optional arguments?: any

any additional arguments that may be needed by an exchange

autoDelete?​

optional autoDelete?: boolean

if true, the exchange will be destroyed once the number of bindings for which it is the source drop to zero.

Default​
false

durable?​

optional durable?: boolean

if true, the exchange will survive broker restarts.

Default​
true

internal?​

optional internal?: boolean

if true, messages cannot be published directly to the exchange (i.e., it can only be the target of bindings, or possibly create messages ex-nihilo).

Default​
false

type?​

optional type?: string

Default​
fanout

subscription?​

optional subscription?: string

Defined in: amqp/src/pubsub.service.ts:22

Queue name used to subscribe, empty to let the broker generate one

Default​

""

type​

type: string

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

Type of the service

Inherited from​

ServiceParameters.type

url​

url: string

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

AMQP connection url

Example​

"amqp://localhost:5672"

Methods​

load()​

load(params?): this

Defined in: amqp/src/pubsub.service.ts:61

Parameters​

params?​

any = {}

the input parameters

Returns​

this

this

Overrides​

ServiceParameters.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​

ServiceParameters.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​

ServiceParameters.with