camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Claus Ibsen (JIRA)" <j...@apache.org>
Subject [jira] Commented: (CAMEL-341) aggregator and JMS: AggregatorStrategy does not get called
Date Sun, 30 Mar 2008 10:17:32 GMT

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

Claus Ibsen commented on CAMEL-341:
-----------------------------------

Gary what is the status of this? CAMEL-352 has been committed.

Is there still a problem? Should it be postponed to be fixed in 1.4 or can we close it?

> 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.


Mime
View raw message