The IronMQ component provides integration with IronMQ a elastic and durable hosted message queue as a service.

The component uses the IronMQ java client library.

To run it requires a IronMQ account, and a project id and token.

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-ironmq</artifactId>
    <!-- use the same version as your Camel core version -->
    <version>x.y.z</version>
</dependency>

URI format

ironmq:queueName[?options]

Where queueName identifies the IronMQ queue you want to publish or consume messages from.

Options

Producer headers

Consumer headers

Message body when producing

Should be either a String or a array of Strings.

In the latter case the batch of strings will be send to IronMQ as one request, creating one message pr. element in the array.

Consumer example

Consume 50 messages pr. poll from the queue 'testqueue' on aws eu, and save the messages to files.

from("ironmq:testqueue?ironMQCloud=https://mq-aws-eu-west-1-1.iron.io&projectId=myIronMQProjectid&token=myIronMQToken&maxMessagesPerPoll=50")
  .to("file:somefolder");

Producer example

Dequeue from activemq jms and enqueue the messages on IronMQ.

from("activemq:foo")
  .to("ironmq:testqueue?projectId=myIronMQProjectid&token=myIronMQToken");