amqp Binding

Feature is in Incubator

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

Zilla runtime amqp binding.

amqp_server:
  type: amqp
  kind: server
  routes:
    - when:
        - address: echo
          capabilities: send_and_receive
    exit: echo_server

Summary

Defines a binding with amqp 1.0 protocol support, with server behavior.

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

Conditional routes based on the link address are used to route these application streams to an exit binding.

Configuration

Properties

• kind*
• routes
• routes[].guarded
• routes[].when
  • when[].address
  • when[].capabilities
• routes[].exit*

* required

kind*

enum [ "server" ]

Behave as an amqp 1.0 proxy.

kind: proxy

exit

string

Default exit binding when no conditional routes are viable.

exit: echo_server

routes

array of object

Conditional amqp-specific routes for adapting http request-response streams to kafka topic streams.

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

routes[].guarded

object as named map of string:string array

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

---

* required