amqp

Send events to AMQP server

Field NameDescriptionTypeDefault
uriAMQP address to send events tostringamqp://localhost//
input-fieldA field from where data is to be read, meaning JSON is assumedfield-
exchangeAn AMQP Exchange--
routing-keyUsed in conjunction with topic exchange, to route datastring-
routing-key-fieldA field containing the routing-key valuestring-
queueAn AMQP Queue--
persistentLet messages be cached and survive server restartboolfalse
durableLet Queue or Exchange survive server restartboolfalse

uri

AMQP address to send events to

Type: string

Example

action:

amqp:
  uri: amqp://localhost//

input-field

A field from where data is to be read, meaning JSON is assumed

Type: field

Example

action:

amqp:
  input-field: some-field
  queue:
    name: some-queue

exchange

An AMQP Exchange

Field NameDescriptionTypeDefault
nameExchange name--
typeExchange type--
passiveAssume Exchange has already been declared, else errorboolfalse

name

Exchange name

Example

action:

amqp:
  exchange:
    name: some-exchange
    kind: fanout

type

Exchange type

There are 2 supported types:

  • fanout: For when same messages are to be consumed by multiple comsumers
  • topic: For when routing keys are to be used

Example

action:

amqp:
  exchange:
    name: some-exchange
    kind: topic
  routing-key: some.key

passive

Assume Exchange has already been declared, else error

Type: bool

Example

action:

amqp:
  exchange:
    name: some-exchange
    passive: true

routing-key

Used in conjunction with topic exchange, to route data

Type: string

routing-key-field

A field containing the routing-key value

Type: string

Example

action:

amqp:
  exchange:
    name: some-exchange
    type: topic
  routing-key-field: some-field

queue

An AMQP Queue

Unlike exchange, this keeps a backlog for when a consumer reconnects to get missed events.

Field NameDescriptionTypeDefault
nameExchange name--
passiveAssume Queue has already been declared, else errorboolfalse

name

Exchange name

Example

action:

amqp:
  queue:
    name: some-exchange

passive

Assume Queue has already been declared, else error

Type: bool

Example

action:

amqp:
  queue:
    name: some-queue
    passive: true

persistent

Let messages be cached and survive server restart

Type: bool

Example

action:

amqp:
  queue:
    name: some-queue
  persistent: true

durable

Let Queue or Exchange survive server restart

Type: bool

Example

action:

amqp:
  queue:
    name: some-queue
  durable: true