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:[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. > > > -- View this message in context: http://www.nabble.com/Aggregator-Problems-tp20085385s22882p20184868.html Sent from the Camel - Users mailing list archive at Nabble.com.
