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.
