Hi, i have done some tests.
It seems that the Stream Resequencing as in fact a "size" when using JMS
This "batch size" is completely linked to the Prefetch size.
If you need more messages than the prefetch size, the resequencer
can't do its job. (I have run the test with 1010 messages as it is a
prefetch of 1000 by default).
With 1010 messages the first one is 11 not 1.
java.lang.AssertionError: Assertion error at index 0 on mock
mock://result with predicate: body == 1 evaluated as: 11 == 1 on
Exchange[JmsMessage: ActiveMQObjectMessage {commandId = 5,
responseRequired = true, messageId =
ID:P210381-2197-1329245016695-2:1000:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:P210381-2197-1329245016695-2:1000:1:1, destination = queue://in2,
transactionId = null, expiration = 0, timestamp = 1329245020929,
arrival = 0, brokerInTime = 1329245020929, brokerOutTime =
1329245020929, correlationId = null, replyTo = null, persistent =
true, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@572090, marshalledProperties =
org.apache.activemq.util.ByteSequence@11c4041, dataStructure = null,
redeliveryCounter = 0, size = 1124, properties = {num=11},
readOnlyProperties = true, readOnlyBody = true, droppable = false}]
I will do some more tests as I expect to reduce the prefetch size to
manage the case where one of the consumer is stuck (prefetch to 0 or
near).
Regards
Hervé
On 2/14/12, Hervé BARRAULT <[email protected]> wrote:
> Thanks, i will do some tests.
>
> Hervé
>
> On 2/14/12, Babak Vahdat <[email protected]> wrote:
>> And if you want to increase the performance (because of the transactional
>> overhead) consider the usage of:
>>
>> cacheLevelName=CACHE_CONSUMER
>>
>> option as already described [1], and in case you want to run the test
>> I've
>> already mentioned by my previous post it would be [2].
>>
>> [1] http://camel.apache.org/jms
>> [2]
>> https://svn.apache.org/repos/asf/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsResequencerTest.java
>>
>> Babak
>>
>> --
>> View this message in context:
>> http://camel.465427.n5.nabble.com/Resequencer-EIP-tp5482502p5482890.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>>
>
