AMQP (RabbitMQ) Source

Consumes messages from an AMQP queue.

Configuration

yaml

source:
  kind: amqp
  connection_string: "amqp://guest:guest@localhost:5672"
  queue: events

Field	Default	Description
`connection_string`	(required)	AMQP connection URI
`queue`	(required)	Queue name
`exchange`		Exchange to bind to
`routing_key`		Routing key for binding
`consumer_tag`	auto-generated	Consumer tag
`prefetch_count`	`10`	Prefetch count
`mode`	`stream`	`stream` or `batch`
`idle_timeout_seconds`	`5`	Batch mode idle timeout

Namespace: amqp.{queue}

CLI

bash

skippr connect source amqp \
  --connection-string 'amqp://guest:guest@localhost:5672' \
  --queue my-queue

Flag	Description
`--connection-string`	AMQP connection URI
`--queue`	Queue name
`--mode`	Consumption mode