camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From RobMMS <robert.pel...@t-systems-mms.com>
Subject RE: Aggregator Problems
Date Tue, 21 Oct 2008 11:52:32 GMT

Hi,
if enabled DEBUG but it's not really telling me anything, maybe you can see
the problem?
I've also tried to change endpoint types (used seda instead of direct, and
log instead of mock), the problem remains.

Fact is that the Problem is somehow related to spring-classes. As I said, if
I just use camel-core package (as well as commons-logging and junit package)
and create a CamelContext, add my route with aggregator to it, everything
works fine (even with a processor attached before aggregate().. )

If I start my CamelContext via the Main() in camel-spring package, OR if i
just include spring-packages like spring-context-2.5.5.jar etc. in my
project, the route doesn't complete.

I've attached the DEBUG output below. Maybe you can find something in there.
for me it looks quite unsuspicious

thx,
Rob


[                          main] DefaultCamelContext            INFO  JMX
enabled. Using InstrumentationLifecycleStrategy.
[                          main] DefaultInstrumentationAgent    DEBUG
Starting JMX agent on server: com.sun.jmx.mbeanserver.JmxMBeanServer@26e431
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=context,name=WUM128085/camel-1
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=context,name=WUM128085/camel-1
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=context,name=WUM128085/camel-1
[                          main] DefaultComponentResolver       DEBUG Found
component: direct via type:
org.apache.camel.component.direct.DirectComponent via
META-INF/services/org/apache/camel/component/direct
[                          main] DefaultComponent               DEBUG
Creating endpoint uri=[direct:start], path=[start], parameters=[{}]
[                          main] DefaultCamelContext            DEBUG
direct:start converted to endpoint: Endpoint[direct:start] by component:
org.apache.camel.component.direct.DirectComponent@c53dce
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=start
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=start
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=start
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]start,type=processor,nodeid=multicast1,name="Multicast[[To[direct:a],
To[direct:b]]]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]start,type=processor,nodeid=multicast1,name="Multicast[[To[direct:a],
To[direct:b]]]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]start,type=processor,nodeid=multicast1,name="Multicast[[To[direct:a],
To[direct:b]]]"
[                          main] DefaultComponent               DEBUG
Creating endpoint uri=[direct:a], path=[a], parameters=[{}]
[                          main] DefaultCamelContext            DEBUG
direct:a converted to endpoint: Endpoint[direct:a] by component:
org.apache.camel.component.direct.DirectComponent@c53dce
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=a
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=a
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=a
[                          main] DefaultComponent               DEBUG
Creating endpoint uri=[direct:b], path=[b], parameters=[{}]
[                          main] DefaultCamelContext            DEBUG
direct:b converted to endpoint: Endpoint[direct:b] by component:
org.apache.camel.component.direct.DirectComponent@c53dce
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=b
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=b
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=b
[                          main] DefaultComponentResolver       DEBUG Found
component: seda via type: org.apache.camel.component.seda.SedaComponent via
META-INF/services/org/apache/camel/component/seda
[                          main] DefaultComponent               DEBUG
Creating endpoint uri=[seda:a], path=[a], parameters=[{}]
[                          main] DefaultCamelContext            DEBUG seda:a
converted to endpoint: Endpoint[seda:a] by component:
org.apache.camel.component.seda.SedaComponent@18fb1f7
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=seda,name=a
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=seda,name=a
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=seda,name=a
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]a,type=processor,nodeid=to3,name="To[direct:merge]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]a,type=processor,nodeid=to3,name="To[direct:merge]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]a,type=processor,nodeid=to3,name="To[direct:merge]"
[                          main] DefaultComponent               DEBUG
Creating endpoint uri=[direct:merge], path=[merge], parameters=[{}]
[                          main] DefaultCamelContext            DEBUG
direct:merge converted to endpoint: Endpoint[direct:merge] by component:
org.apache.camel.component.direct.DirectComponent@c53dce
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=merge
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=merge
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=direct,name=merge
[                          main] DefaultComponent               DEBUG
Creating endpoint uri=[seda:b], path=[b], parameters=[{}]
[                          main] DefaultCamelContext            DEBUG seda:b
converted to endpoint: Endpoint[seda:b] by component:
org.apache.camel.component.seda.SedaComponent@18fb1f7
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=seda,name=b
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=seda,name=b
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=seda,name=b
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]b,type=processor,nodeid=to4,name="To[direct:merge]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]b,type=processor,nodeid=to4,name="To[direct:merge]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]b,type=processor,nodeid=to4,name="To[direct:merge]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]merge,type=processor,nodeid=aggregator1,name="Aggregator[
Expression[null] -> [To[mock:end]]]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]merge,type=processor,nodeid=aggregator1,name="Aggregator[
Expression[null] -> [To[mock:end]]]"
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]merge,type=processor,nodeid=aggregator1,name="Aggregator[
Expression[null] -> [To[mock:end]]]"
[                          main] DefaultComponentResolver       DEBUG Found
component: mock via type: org.apache.camel.component.mock.MockComponent via
META-INF/services/org/apache/camel/component/mock
[                          main] DefaultComponent               DEBUG
Creating endpoint uri=[mock:end], path=[end], parameters=[{}]
[                          main] DefaultCamelContext            DEBUG
mock:end converted to endpoint: Endpoint[mock:end] by component:
org.apache.camel.component.mock.MockComponent@1ccce3c
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=mock,name=end
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=mock,name=end
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,type=endpoint,component=mock,name=end
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]start,type=route,name=[direct]start
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]start,type=route,name=[direct]start
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[direct]start,type=route,name=[direct]start
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]a,type=route,name=[seda]a
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]a,type=route,name=[seda]a
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]a,type=route,name=[seda]a
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]b,type=route,name=[seda]b
[                          main] DefaultInstrumentationAgent    DEBUG
Registering MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]b,type=route,name=[seda]b
[                          main] DefaultInstrumentationAgent    DEBUG
Registered MBean with objectname:
org.apache.camel:context=WUM128085/camel-1,route=[seda]b,type=route,name=[seda]b
[                          main] DefaultCamelContext            DEBUG Adding
routes from: Routes: [Route[ [From[direct:start]] ->
[Interceptor[Delegate(DeadLetterChannel[StreamCachingInterceptor,
RecipientList[log:org.apache.camel.DeadLetterChannel?level=error],
RedeliveryPolicy[maximumRedeliveries=6]])]]], Route[ [From[seda:a]] ->
[Interceptor[Delegate(DeadLetterChannel[Delegate(TraceInterceptor[To[direct:merge]]),
RecipientList[log:org.apache.camel.DeadLetterChannel?level=error],
RedeliveryPolicy[maximumRedeliveries=6]])]]], Route[ [From[seda:b]] ->
[Interceptor[Delegate(DeadLetterChannel[Delegate(TraceInterceptor[To[direct:merge]]),
RecipientList[log:org.apache.camel.DeadLetterChannel?level=error],
RedeliveryPolicy[maximumRedeliveries=6]])]]], Route[ [From[direct:merge]] ->
[Interceptor[Delegate(DeadLetterChannel[Delegate(TraceInterceptor[Aggregator[
Expression[null] -> [To[mock:end]]]]),
RecipientList[log:org.apache.camel.DeadLetterChannel?level=error],
RedeliveryPolicy[maximumRedeliveries=6]])]]]] routes: []
[                          main] ProducerCache                  DEBUG >>>>
Endpoint[direct:start] Exchange[Message: testMsg]
[                          main] TraceInterceptor               INFO 
ID-WUM128085/2059-1224589174803/2-0 -> interceptor1
Interceptor[Delegate(DeadLetterChannel[StreamCachingInterceptor,
RecipientList[log:org.apache.camel.DeadLetterChannel?level=error],
RedeliveryPolicy[maximumRedeliveries=6]])] InOnly Properties:{}
Headers:{ID=1} BodyType:String Body:testMsg
[                          main] ResolverUtil                   DEBUG
Searching for annotations of org.apache.camel.Converter in packages:
[org.apache.camel.converter, org.apache.camel.spring.converter]
[                          main] ResolverUtil                   DEBUG
Searching for: annotated with @Converter in package:
org/apache/camel/converter using classloader:
sun.misc.Launcher$AppClassLoader
[                          main] ResolverUtil                   DEBUG It's
not an osgi bundle classloader
[                          main] ResolverUtil                   DEBUG
Getting resource URL for package: org/apache/camel/converter with
classloader: sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG URL
from classloader:
jar:file:/C:/Dokumente%20und%20Einstellungen/rop/.m2/repository/org/apache/camel/camel-core/1.4.0/camel-core-1.4.0.jar!/org/apache/camel/converter
[                          main] ResolverUtil                   DEBUG
Decoded urlPath: file:/C:/Dokumente und
Einstellungen/rop/.m2/repository/org/apache/camel/camel-core/1.4.0/camel-core-1.4.0.jar!/org/apache/camel/converter
[                          main] ResolverUtil                   DEBUG
Scanning for classes in [/C:/Dokumente und
Einstellungen/rop/.m2/repository/org/apache/camel/camel-core/1.4.0/camel-core-1.4.0.jar]
matching criteria: annotated with @Converter
[                          main] ResolverUtil                   DEBUG
Loading from jar: C:\Dokumente und
Einstellungen\rop\.m2\repository\org\apache\camel\camel-core\1.4.0\camel-core-1.4.0.jar
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.CamelConverter$1 matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.CamelConverter$2 matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.CamelConverter matches criteria
[annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.CamelConverter in classloader:
sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.CollectionConverter matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.CollectionConverter in classloader:
sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.HasAnnotation matches criteria
[annotated with @Converter]
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.IOConverter matches criteria
[annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.IOConverter in classloader:
sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.NIOConverter matches criteria
[annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.NIOConverter in classloader:
sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.ObjectConverter matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.ObjectConverter in classloader:
sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.jaxp.BytesSource matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.jaxp.DomConverter matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.jaxp.DomConverter in classloader:
sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.jaxp.StaxConverter matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.jaxp.StaxConverter in classloader:
sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.jaxp.StreamSourceConverter
matches criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.jaxp.StreamSourceConverter in
classloader: sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.jaxp.StringSource matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.jaxp.XmlConverter matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.jaxp.XmlConverter in classloader:
sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.stream.StreamCache matches
criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG
Testing for class
org.apache.camel.converter.stream.StreamCacheConverter$InputStreamCache
matches criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG
Testing for class
org.apache.camel.converter.stream.StreamCacheConverter$StreamSourceCache
matches criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG
Testing for class org.apache.camel.converter.stream.StreamCacheConverter
matches criteria [annotated with @Converter]
[                          main] ResolverUtil                   DEBUG Found
class: class org.apache.camel.converter.stream.StreamCacheConverter in
classloader: sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG
Searching for: annotated with @Converter in package:
org/apache/camel/spring/converter using classloader:
sun.misc.Launcher$AppClassLoader
[                          main] ResolverUtil                   DEBUG It's
not an osgi bundle classloader
[                          main] ResolverUtil                   DEBUG
Getting resource URL for package: org/apache/camel/spring/converter with
classloader: sun.misc.Launcher$AppClassLoader@133056f
[                          main] ResolverUtil                   DEBUG No
URLs returned by classloader
[                          main] ResolverUtil                   DEBUG Found:
[class org.apache.camel.converter.jaxp.DomConverter, class
org.apache.camel.converter.NIOConverter, class
org.apache.camel.converter.jaxp.StreamSourceConverter, class
org.apache.camel.converter.jaxp.StaxConverter, class
org.apache.camel.converter.ObjectConverter, class
org.apache.camel.converter.CollectionConverter, class
org.apache.camel.converter.CamelConverter, class
org.apache.camel.converter.stream.StreamCacheConverter, class
org.apache.camel.converter.jaxp.XmlConverter, class
org.apache.camel.converter.IOConverter]
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class: org.apache.camel.converter.jaxp.DomConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class: org.apache.camel.converter.NIOConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class:
org.apache.camel.converter.jaxp.StreamSourceConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class: org.apache.camel.converter.jaxp.StaxConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class: org.apache.camel.converter.ObjectConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class: org.apache.camel.converter.CollectionConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class: org.apache.camel.converter.CamelConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class:
org.apache.camel.converter.stream.StreamCacheConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class: org.apache.camel.converter.jaxp.XmlConverter
[                          main] AnnotationTypeConverterLoader  DEBUG
Loading converter class: org.apache.camel.converter.IOConverter
[               pool-1-thread-1] TraceInterceptor               INFO 
ID-WUM128085/2059-1224589174803/2-0 -> to1 To[direct:a] InOnly
Properties:{CamelCauseException=null} Headers:{ID=1} BodyType:String
Body:testMsg
[               pool-1-thread-1] DirectProducer                 WARN  No
getConsumers() available on Producer[direct:a] for Exchange[Message:
testMsg]
[               pool-1-thread-2] TraceInterceptor               INFO 
ID-WUM128085/2059-1224589174803/2-0 -> to2 To[direct:b] InOnly
Properties:{CamelCauseException=null} Headers:{ID=1} BodyType:String
Body:testMsg
[               pool-1-thread-2] DirectProducer                 WARN  No
getConsumers() available on Producer[direct:b] for Exchange[Message:
testMsg]
[                          main] InstrumentationProcessor       DEBUG
Recording duration: 150.903861 millis for exchange: Exchange[Message:
testMsg]
[                          main] MockEndpoint                   INFO 
Asserting: Endpoint[mock:end] is satisfied
[                          main] MockEndpoint                   DEBUG
Waiting on the latch for: 20000 millis




Claus Ibsen wrote:
> 
> Hi
> 
> Could you try with org.apache.camel DEBUG logging?
> And try using different endpoints, such as log instead of mock if you
> think there is a problem. Maybe try using seda instead of direct. 
> 
> But the logging should help.
> 
> 
> Med venlig hilsen
>  
> Claus Ibsen
> ......................................
> Silverbullet
> Skovsgårdsvænget 21
> 8362 Hørning
> Tlf. +45 2962 7576
> Web: www.silverbullet.dk
> 
> -----Original Message-----
> From: RobMMS [mailto:robert.pelger@t-systems-mms.com] 
> Sent: 21. oktober 2008 10:53
> To: camel-user@activemq.apache.org
> Subject: RE: Aggregator Problems
> 
> 
> Hi,
> I just tried out without a processor:
> from("direct:merge").aggregator(header("ID")).batchSize(2).to("mock:end");
> 
> The problem stays the same, I don't get it aggregated, which means, no
> message on mock:end. 
> 
> 
> Rob 
> 
> 
> 
> 
> Claus Ibsen wrote:
>> 
>> Hi
>> 
>> See known issues in the 1.5 release notes (work in progress).
>> http://activemq.apache.org/camel/camel-150-release.html
>> 
>> You can not have anything between from ... aggregator, this is currently
>> not supported (bypassed in 1.4). aggregator must be connected directly to
>> the consumer, so you should do
>> 
>> From(x).aggregator = OK
>> From(x).process(z).aggregator = NOT OK
>> 
>> 
>> The issue is reported in CAMEL-393
>> 
>> 
>> 
>> Med venlig hilsen
>>  
>> Claus Ibsen
>> ......................................
>> Silverbullet
>> Skovsgårdsvænget 21
>> 8362 Hørning
>> Tlf. +45 2962 7576
>> Web: www.silverbullet.dk
>> -----Original Message-----
>> From: RobMMS [mailto:robert.pelger@t-systems-mms.com] 
>> Sent: 21. oktober 2008 10:08
>> To: camel-user@activemq.apache.org
>> Subject: Aggregator Problems
>> 
>> 
>> Hi,
>> I've implemented a simple test for Aggregator pattern:
>> 
>> public void testAggregator() throws Exception {
>> 		cc.addRoutes(new RouteBuilder() {
>> 
>> 			@Override
>> 			public void configure() throws Exception {
>> 				from("direct:start").multicast(null, true).to("direct:a",
>> "direct:b");
>> 				
>> 				from("direct:a").process(new MockProcessor("a:
>> ")).to("direct:merge");
>> 				from("direct:b").process(new MockProcessor("b:
>> ")).to("direct:merge");
>> 				
>> 				from("direct:merge").process(new MockProcessor("MergeIn: "))
>> 					.aggregator(header("ID")).batchSize(2)			
>> 					.to("mock:end");				
>> 			}			
>> 		});
>> 		
>> 		pt.sendBodyAndHeader("direct:start", "testMsg", "ID", 1);
>> 		
>> 		MockEndpoint mock = (MockEndpoint) cc.getEndpoint("mock:end");
>> 		mock.expectedMessageCount(1);
>> 		mock.assertIsSatisfied();		
>> 	}
>> // where cc is a DefaultCamelContext and
>> // pt is a ProducerTemplate
>> 
>> I'm working with Camel 1.4, and to get this above code running, I need to
>> import
>> camel-core-1.4.jar
>> commons-logging-1.1.1.jar
>> junit-4.4.jar
>> 
>> BUT, the problem is, when I'm trying to use this pattern in a bigger
>> project, where also some spring-jars are needed it doesn't work anymore.
>> It
>> seems to time out, i.e. the MockEndpoint doesn't receive any message. 
>> I figured out that this weird behaviour occurs when I, in addition to the
>> above jars, have imported the following spring-jars into projects
>> classpath:
>> 
>> spring-core-2.5.5.jar
>> spring-context-2.5.5.jar
>> spring-beans-2.5.5.jar
>> spring-aop-2.5.5.jar
>> 
>> The log says:
>> WARNUNG: No getConsumers() available on Producer[direct:merge] for
>> Exchange[Message:  aggTest ]
>> 
>> So it seems that the route 
>> from("direct:merge").process(new MockProcessor("MergeIn: "))
>> 					.aggregator(header("ID")).batchSize(2)			
>> 					.to("mock:end");	
>> isn't correctly loaded? 
>> 
>> There seems to be a (hidden) dependency somewhere, I guess. But I need to
>> get it running really urgently, with Camel 1.4 and Spring 2.5.5 actually.
>> 
>> 
>> Thanks,
>> Rob
>> 
>> -- 
>> View this message in context:
>> http://www.nabble.com/Aggregator-Problems-tp20085385s22882p20085385.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>> 
>> 
>> 
> 
> -- 
> View this message in context:
> http://www.nabble.com/Aggregator-Problems-tp20085385s22882p20086029.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Aggregator-Problems-tp20085385s22882p20088628.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Mime
View raw message