amqp Binding

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.

Feature is in Incubator

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

server

Full config

The amqp server binding decodes the AMQP protocol on the inbound network stream, producing higher level application streams for each send or receive link.

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