fq

The fq module consumed and publishes message via fq.

• loader: C
• image: fq.so

Module Configuration

• poll_limit (optional) [default: 10000]

  allowed: /^\d+$/

  Maximum number of messages to handle in a single callback.

• fanout_pool (optional) [default: default]

  allowed: /^\S+$/

  The eventer pool in which to run the poller.

• fanout () [default: 1]

  allowed: /^\d+$/

  The number of threads in the pool on which to run the poller. A value less than or equal to zero results in the full concurrency of the pool.

Examples

Loading the fq module.

      <root>
        <modules>
          <module image="fq" name="fq">
            <config>
              <poll_limit>1000</poll_limit>
            </config>
          </module>
        </modules>
        <network>
          <mq type="fq">
            <host>localhost</host>
            <port>8765</port>
            <user>user</user>
            <pass>pass</pass>
            <exchange>exchange</exchange>
            <program>prefix:"in."</program>
          </mq>
          <mq type="fq">
            <host>localhost</host>
            <port>8765</port>
            <user>user</user>
            <pass>pass</pass>
            <exchange>exchange</exchange>
            <program>prefix:"in2."</program>
          </mq>
        </network>
      </root>