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:[EMAIL PROTECTED] Sent: 21. oktober 2008 13:53 To: [email protected] 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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: [EMAIL PROTECTED] [ 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:[EMAIL PROTECTED] > Sent: 21. oktober 2008 10:53 > To: [email protected] > 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:[EMAIL PROTECTED] >> Sent: 21. oktober 2008 10:08 >> To: [email protected] >> 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.
