You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by "Gary Tully (JIRA)" <ji...@apache.org> on 2008/02/28 11:27:17 UTC
[jira] Work started: (CAMEL-341) aggregator and JMS:
AggregatorStrategy does not get called
[ https://issues.apache.org/activemq/browse/CAMEL-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Work on CAMEL-341 started by Gary Tully.
> aggregator and JMS: AggregatorStrategy does not get called
> ----------------------------------------------------------
>
> Key: CAMEL-341
> URL: https://issues.apache.org/activemq/browse/CAMEL-341
> Project: Apache Camel
> Issue Type: Bug
> Components: camel-jms
> Affects Versions: 1.3.0
> Environment: Mac OS X 10.5.2 JDK 1.5
> Reporter: Andrea Chiodoni
> Assignee: Gary Tully
> Fix For: 1.3.0
>
> Attachments: sample.zip
>
>
> Hi I'm using camel 1.3-SNAPSHOT. I don't get the aggregator to work as expected when messages come from a JMS endpoint and sent to a bean. I've tried the following configuration:
> //private static final String ENDPOINT = "jms:myqueue";
> private static final String ENDPOINT = "direct:myqueue";
> from(ENDPOINT).aggregator(header("JMSCorrelationId"),new MyAggregatorStrategy()).bean(new SomeBean());
> With ENDPOINT = "jms:myqueue" I get:
> [ Thread-1] MyRouteBuilder INFO Sending: message:1
> [ Thread-1] MyRouteBuilder INFO Sending: message:2
> [ Thread-1] MyRouteBuilder INFO Sending: message:3
> [meBean@3c2797]] Polling Thread] MyRouteBuilder INFO Received: message:2 (null)
> End with ENDPOINT = "direct:myqueue" I get:
> [ Thread-1] MyRouteBuilder INFO Sending: message:1
> [ Thread-1] MyRouteBuilder INFO Sending: message:2
> [ Thread-1] MyRouteBuilder INFO Sending: message:3
> [meBean@3c2797]] Polling Thread] MyAggregatorStrategy INFO Strategy: message:1, message:2
> [meBean@3c2797]] Polling Thread] MyAggregatorStrategy INFO Strategy: message:1, message:2, message:3
> [meBean@3c2797]] Polling Thread] MyRouteBuilder INFO Received: message:1, message:2, message:3 (null)
> Only with ENDPOINT = "direct:myqueue" I get the expected behavior.
> I've noticed the AggregatorStrategy even does not get called while using the JMS endpoit.
> I upload the complete sample (sample.zip)
> There is also a second issue I can not explain: on the sample I've tried to use a JMSCorrelationId but printing @Header(name="JMSCorrelationID") String correlationID I get "null".
> PS: Same sample using 1.2.0, the AggregatorStrategy get called but I loose message 2
> [ Thread-1] MyRouteBuilder INFO Sending: message:1
> [ Thread-1] MyRouteBuilder INFO Sending: message:2
> [ Thread-1] MyRouteBuilder INFO Sending: message:3
> [meBean@2cfeb7]] Polling Thread] MyAggregatorStrategy INFO Strategy: message:1, message:3
> [meBean@2cfeb7]] Polling Thread] MyRouteBuilder INFO Received: message:1, message:3 (null)
> Andrea
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.