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 Mon, 27 Oct 2008 10:16:28 GMT

Hi,
i disabled JMX and it works now. Thanks!


Rob



Claus Ibsen wrote:
> 
> Hi
> 
> This is kinda strange. When you have spring-context.jar on the classpath
> then Camel enables JMX instrumentation so you can manage Camel routes
> using JMX.
> 
> Could you try disabling JMX:
> http://activemq.apache.org/camel/camel-jmx.html
> 
> You could also try, for a moment, with the newer Camel 1.5 that we will
> cut a RC pretty soon.
> http://activemq.apache.org/camel/download.html
> 
> If still a problem then you can email me your project and I can try on my
> system: davsclaus at apache dot org.
> 
> 
> 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 13:53
> To: camel-user@activemq.apache.org
> Subject: RE: Aggregator Problems
> 
> 
> 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.
> 
> 
> 

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


Mime
View raw message