amqp

The amqp module consumes and publishes message via AMQP (RabbitMQ).

  • loader: C
  • image: amqp.so

Module Configuration

  • poll_limit (optional) [default: 10000]

    allowed: /^\d+$/

    Maximum number of messages to handle in a single callback.

    Examples

Loading the amqp module.

      <root>
        <modules>
          <module image="amqp" name="amqp"/>
            <config>
              <poll_limit>1000</poll_limit>
            </config>
        </modules>
        <network>
          <mq type="amqp">
            <host>localhost</host>
            <port>8765</port>
            <user>user</user>
            <pass>pass</pass>
            <exchange>exchange</exchange>
            <routingkey>foo.*</routingkey>
          </mq>
          <mq type="amqp">
            <host>localhost</host>
            <port>8765</port>
            <user>user</user>
            <pass>pass</pass>
            <exchange>exchange</exchange>
            <routingkey>bob.#</routingkey>
          </mq>
        </network>
      </root>

results matching ""

    No results matching ""