RabbitMQ

Install

cargo install faucet-cli --features source-rabbitmq
faucet init --source rabbitmq

# Cargo.toml — use it as a library
cargo add faucet-source-rabbitmq

Starter config

source:
  type: rabbitmq
  config:
    # url: ""    # Full AMQP URI, e.g.
    # host: ""    # Broker host.
    # port: 0    # Broker port.
    # vhost: ""    # Virtual host.
    # auth: { type: none }    # one of: none, plain, external
      # --- Alternative variants — replace the block above with one of these ---
      # type: plain
      # config:
        # username: ""    # REQUIRED
        # password: ""    # REQUIRED
      #
      # type: external
    # tls: { ... }    # TLS (`amqps://`) settings.
    # connection_name: ""    # Client connection name shown in the RabbitMQ management UI.
    # heartbeat_secs: 0    # Requested heartbeat interval in seconds (`0` disables heartbeats).
    # connect_timeout_secs: 30    # Upper bound, in seconds, on establishing the connection (TCP + AMQP handshake, including any retries).
    # connect_retries: 0    # Extra TCP connect attempts (exponential backoff) before giving up.
    queue: ""    # REQUIRED — Queue to consume from.
    # declare_queue: true    # Declare the queue before consuming (idempotent when it already exists with the same properties).
    # queue_durable: true    # Whether a declared queue is durable (survives a broker restart).
    # bindings: []    # Exchange → queue bindings to declare before consuming.
    # prefetch: 0    # Consumer QoS window: the most unacknowledged deliveries the broker sends ahead.
    # ack_mode: null    # When deliveries are acknowledged to the broker.
    # value_format: null    # How a message body maps to and from a JSON record.
    # on_decode_error: null    # What to do with a message whose body does not decode under `value_format`.
    # include_metadata: false    # Wrap each record as `{ "data": <body>, "exchange", "routing_key", "delivery_tag", "redelivered", "headers", … }` instead of emitting the decoded body alone.
    # consumer_tag: ""    # Consumer tag.
    # max_messages: 0    # Stop after this many messages.
    # idle_timeout_secs: 0    # Stop after this many seconds with no new message.
    # batch_size: 1000    # Messages per emitted page (and per acknowledgement under `on_sink_confirm`).

Capabilities

Config fields