[ 
https://issues.apache.org/activemq/browse/CAMEL-1037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=47945#action_47945
 ] 

William Tam commented on CAMEL-1037:
------------------------------------

Nice work, Martin!  I am looking to apply this patch but testBatchResequencer() 
is failing on me.  Do you have any suggestion?  I'm on 1.x currently. 

java.lang.AssertionError: mock:result body == 9 failed on Exchange[JmsMessage: 
ActiveMQObjectMessage {commandId = 5, responseRequired = true, messageId = 
ID:lenw500-55044-1228766892918-2:113:1:1:1, originalDestination = null, 
originalTransactionId = null, producerId = 
ID:lenw500-55044-1228766892918-2:113:1:1, destination = queue://out, 
transactionId = null, expiration = 0, timestamp = 1228766893813, arrival = 0, 
brokerInTime = 1228766893813, brokerOutTime = 1228766893813, correlationId = 
null, replyTo = null, persistent = true, type = null, priority = 4, groupID = 
null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = 
null, content = [EMAIL PROTECTED], marshalledProperties = null, dataStructure = 
null, redeliveryCounter = 0, size = 1106, properties = {num=11}, 
readOnlyProperties = true, readOnlyBody = true, droppable = false}] with left 
value <11> right value <9>
        at 
org.apache.camel.builder.BinaryPredicateSupport.assertMatches(BinaryPredicateSupport.java:57)
        at 
org.apache.camel.builder.BinaryPredicateSupport.assertMatches(BinaryPredicateSupport.java:1)
        at 
org.apache.camel.component.mock.AssertionClause.applyAssertionOn(AssertionClause.java:114)
        at 
org.apache.camel.component.mock.MockEndpoint$8.run(MockEndpoint.java:496)
        at 
org.apache.camel.component.mock.MockEndpoint.assertIsSatisfied(MockEndpoint.java:249)
        at 
org.apache.camel.component.mock.MockEndpoint.assertIsSatisfied(MockEndpoint.java:214)
        at 
org.apache.camel.component.jms.issues.JmsResequencerTest.testResequencer(JmsResequencerTest.java:66)
        at 
org.apache.camel.component.jms.issues.JmsResequencerTest.testBatchResequencer(JmsResequencerTest.java:51)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
        at java.lang.reflect.Method.invoke(Method.java:585)
        at junit.framework.TestCase.runTest(TestCase.java:164)
        at 
org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests.runManaged(AbstractJUnit38SpringContextTests.java:307)
        at 
org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests.access$000(AbstractJUnit38SpringContextTests.java:94)
        at 
org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests$1.run(AbstractJUnit38SpringContextTests.java:193)
        at 
org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests.runTest(AbstractJUnit38SpringContextTests.java:270)
        at 
org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests.runTestTimed(AbstractJUnit38SpringContextTests.java:228)
        at 
org.springframework.test.context.junit38.AbstractJUnit38SpringContextTests.runBare(AbstractJUnit38SpringContextTests.java:191)
        at junit.framework.TestResult$1.protect(TestResult.java:106)
        at junit.framework.TestResult.runProtected(TestResult.java:124)
        at junit.framework.TestResult.run(TestResult.java:109)
        at junit.framework.TestCase.run(TestCase.java:120)
        at 
org.eclipse.jdt.internal.junit.runner.junit3.JUnit3TestReference.run(JUnit3TestReference.java:130)
        at 
org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
        at 
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
        at 
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
        at 
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
        at 
org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)



> Messages in Resequencer between 2 JMS queues get stuck
> ------------------------------------------------------
>
>                 Key: CAMEL-1037
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-1037
>             Project: Apache Camel
>          Issue Type: Bug
>          Components: camel-core
>    Affects Versions: 1.5.0
>            Reporter: Jonathan Anstey
>            Assignee: William Tam
>         Attachments: camel-1.x.patch, camel-2.0.patch
>
>
> Martin describes the issue as follows in CAMEL-1034:
> "The issue with the regular resequencer (the one that extends the 
> BatchProcessor) remains because the process(Exchange) method is empty. In 
> addition to the BatchProcessor's polling consumer, an additional JmsConsumer 
> is created by the JMS endpoint that competes with the polling consumer. The 
> JmsConsumer then calls the empty process(Exchange) method and the exchange is 
> lost."

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.

Reply via email to