SQS Component

Available as of Camel 2.6

The sqs component supports sending and receiving messages to Amazon's SQS service.

URI Format

sqs://queue-name

URI Options

Name	Default Value	Context	Description
accessKey	null	Shared	Amazon AWS Access Key
secretKey	null	Shared	Amazon AWS Secret Key
attributeNames
defaultVisibilityTimeout
deleteAfterRead	true	Consumer	Delete message from SQS after it has been read
maxMessagesPerPoll
visibilityTimeout

Usage

Batch Consumer

This component implements the Batch Consumer.

Exchange Properties, sqs consumer only

As the sqs consumer is BatchConsumer it supports batching the messages it polls. By batching it means that Camel will add some properties to the Exchange so you know the number of messages polled the current index in that order.

Property	Description
`CamelBatchSize`	The total number of messages that was polled in this batch.
`CamelBatchIndex`	The current index of the batch. Starts from 0.
`CamelBatchComplete`	A `boolean` value indicating the last Exchange in the batch. Is only `true` for the last entry.

This allows you for instance to know how many messages exists in this batch and for instance let the Aggregator aggregate this number of messages.

Dependencies

Maven users will need to add the following dependency to their pom.xml.

pom.xml

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-aws</artifactId>
    <version>${camel-version}</version>
</dependency>

where ${camel-version} must be replaced by the actual version of Camel (2.6 or higher).

[CONF] Apache Camel > sqs

sqs

Page edited by Tracy Snell

Changes (3)

Full Content