AMQP (RabbitMQ) Destination

Publishes records as JSON messages to an AMQP exchange.

Configuration

warehouse:
  kind: amqp
  connection_string: "amqp://guest:guest@localhost:5672"
  exchange: events
  routing_key: output

Field	Default	Description
connection_string	(required)	AMQP connection URI
exchange	(required)	Exchange name
routing_key	""	Routing key
exchange_type	direct	Exchange type (direct, fanout, topic, headers)