amqp

Read from AMQP queues

Field NameDescriptionTypeDefault
queueAn AMQP Queue--
uriAMQP address to listen tostringamqp://localhost//
routing-keyUsed in conjunction with topic exchange, to route datastring-
exchangeAn AMQP Exchange--
persistentLet messages be cached and survive server restartboolfalse
durableLet Queue or Exchange survive server restartboolfalse
rawAssume incoming data is in JSON format (do not quote)boolfalse
ignore-line-breaksDo not treat separate lines as distinct eventsboolfalse

queue

An AMQP Queue

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

name

Queue name

Example

action:

amqp:
  queue:
    name: queue-name

passive

Assume Queue has already been declared, else error

Type: bool

Example

action:

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

uri

AMQP address to listen to

Type: string

Example

action:

amqp:
  queue:
    name: queue-name
  uri: amqp://localhost//

routing-key

Used in conjunction with topic exchange, to route data

Type: string

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

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

raw

Assume incoming data is in JSON format (do not quote)

Type: bool

Example

action:

amqp:
  queue:
    name: queue-name
  raw: true

ignore-line-breaks

Do not treat separate lines as distinct events

Type: bool

Example

action:

amqp:
  queue:
    name: some-queue
  ignore-line-breaks: true