AMQP

The Advanced Message Queuing Protocol (AMQP) is an open standard application layer protocol for message-oriented middleware.

The diagram below shows the key abstractions and how they relate to a pipeline:

Tenzir supports sending and receiving messages via AMQP version 0-9-1.

URL Support

The URL scheme amqp:// dispatches to load_amqp and save_amqp for seamless URL-style use via from and to.

Examples

Send events to an AMQP exchange

from {
  x: 42,
  y: "foo",
}
to "amqp://admin:pass@0.0.0.1:5672/vhost"

Receive events from an AMQP queue

from "amqp://admin:pass@0.0.0.1:5672/vhost"