Output: amqp
Send events to AMQP server
Field Summary
| Field Name | Type | Description | Default |
|---|---|---|---|
| uri | string | AMQP address to send events to | amqp://localhost// |
| input-field | field | A field from where data is to be read, meaning JSON is assumed | - |
| exchange | Exchange | An AMQP Exchange | - |
| routing-key | string | Used in conjunction with topic exchange, to route data | - |
| routing-key-field | field | A field containing the routing-key value | - |
| queue | Queue | An AMQP Queue | - |
| persistent | bool | Let messages be cached and survive server restart | false |
| durable | bool | Let Queue or Exchange survive server restart | false |
Fields
uri
Type: string
Default: amqp://localhost//
AMQP address to send events to
Example
Pipe Language Snippet:
amqp:
uri: amqp://localhost//
input-field
Type: field
A field from where data is to be read, meaning JSON is assumed
Example
Pipe Language Snippet:
amqp:
input-field: some-field
queue:
name: some-queue
exchange
Type: Exchange
An AMQP Exchange
| Field Name | Type | Description | Default |
|---|---|---|---|
| name | string | Exchange name | - |
| type | string | Exchange type | - |
| passive | bool | Assume Exchange has already been declared, else error | false |
name
Type: string
Exchange name
Example
Pipe Language Snippet:
amqp:
exchange:
name: some-exchange
type: fanout
type
Type: string
Possible Values: fanout, topic, direct
Exchange type
There are 2 supported types:
- fanout: For when same messages are to be consumed by multiple comsumers
- topic: Topic-based pub-sub
- direct: For when routing keys are to be used
Example
Pipe Language Snippet:
amqp:
exchange:
name: some-exchange
type: topic
routing-key: some.key
passive
Type: bool
Default: false
Assume Exchange has already been declared, else error
Example
Pipe Language Snippet:
amqp:
exchange:
name: some-exchange
passive: true
routing-key
Type: string
Used in conjunction with topic exchange, to route data
routing-key-field
Type: field
A field containing the routing-key value
Example
Pipe Language Snippet:
amqp:
exchange:
name: some-exchange
type: topic
routing-key-field: some-field
queue
Type: Queue
An AMQP Queue
Unlike exchange, this keeps a backlog for when a consumer
reconnects to get missed events.
| Field Name | Type | Description | Default |
|---|---|---|---|
| name | string | Queue name | - |
| passive | bool | Assume Queue has already been declared, else error | false |
name
Type: string
Queue name
Example
Pipe Language Snippet:
amqp:
queue:
name: queue-name
passive
Type: bool
Default: false
Assume Queue has already been declared, else error
Example
Pipe Language Snippet:
amqp:
queue:
name: some-queue
passive: true
persistent
Type: bool
Default: false
Let messages be cached and survive server restart
Example
Pipe Language Snippet:
amqp:
queue:
name: some-queue
persistent: true
durable
Type: bool
Default: false
Let Queue or Exchange survive server restart
Example
Pipe Language Snippet:
amqp:
queue:
name: some-queue
durable: true