Hello List,
I'm trying to use the AmazonSQSBufferedAsyncClient to send out batched
messages to the queue.
My Config of the Client:
<bean name="sqsBufferedConfig"
class="com.amazonaws.services.sqs.buffered.QueueBufferConfig">
<property name="maxBatchOpenMs" value="5000"/>
</bean>
<bean name="sqsBufferedClient"
class="com.amazonaws.services.sqs.buffered.AmazonSQSBufferedAsyncClient">
<constructor-arg ref="sqsClient"/>
<constructor-arg ref="sqsBufferedConfig"/>
</bean>
and the context I'm using the client in:
<split>
<xpath>//orderId/text()</xpath>
<to
uri="aws-sqs://my_queue?amazonSQSClient=#sqsBufferedClient" />
</split>
My expectation is that the client batches all requests coming in within 5
seconds and sending them in one batch then. What acually happens ist that
the client receives the first message, waits 5 seconds(waiting for more
messages to come, which obviously don't come in) and sends out the batch
then with the size of 1.
--
View this message in context:
http://camel.465427.n5.nabble.com/AmazonSQSBufferedAsyncClient-doesn-t-batch-messages-tp5806711.html
Sent from the Camel - Users mailing list archive at Nabble.com.
