amqp server

The amqp server binding decodes the AMQP protocol on the inbound network stream, producing higher level application streams for each send or receive link. Defines a binding with AMQP 1.0 protocol support, with server behavior. Conditional routes based on the link address are used to route these application streams to an exit binding.

amqp_server:
  type: amqp
  kind: server
  exit: default_exit
  routes:
    - guarded:
        my_guard:
          - read:items
    - when:
        - address: echo
          capabilities: send_and_receive
      exit: routed_exit

Feature is in Incubator

Read how to enable incubator features. Star and watch the Zilla repo for new releases!

Configuration (* required)

routes

array of object

Conditional amqp specific routes.

routes:
  - when:
      - address: echo
        capabilities: send_and_receive
      exit: echo_server

routes[].guarded

object as map of named array of string

List of roles required by each named guard to authorize this route.

routes:
  - guarded:
      my_guard:
        - read:items

routes[].when

array of object

List of conditions (any match) to match this route. Read more: When a route matches

routes:
  - when:
      - address: echo
        capabilities: send_and_receive

when[].address

string

Link address.

when[].capabilities

enum [ send_only, receive_only, send_and_receive ] | Default: send_and_receive

Send or receive, or both.

routes[].exit

string

Next binding when following this route.

routes:
  - when:
    ...
    exit: echo_server

exit

string

Default exit binding when no conditional routes are viable.

exit: echo_server

telemetry

object

Defines the desired telemetry for the binding.

telemetry.metrics

array

Telemetry metrics to track

telemetry:
  metrics:
    - stream.*