You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Christian Müller <ch...@gmail.com> on 2011/08/22 22:36:12 UTC
Stop a route for unit testing
Hello all!
I'm using Camel 2.6.0 (I got the same result with Camel 2.8.0).
I have a Camel context with two simple routes:
public class Route1 extends RouteBuilder {
@Override
public void configure() throws Exception {
from("file://src/test/data?noop=true&initialDelay=5000").routeId(Route1.class.getName())
.split(body().tokenize(",")) // the content is
1,2,3,4,5,6,7,8,9,0
.to("activemq:queue:foo")
.end();
}
}
public class Route2 extends RouteBuilder {
@Override
public void configure() throws Exception {
from("activemq:queue:foo").routeId(Route2.class.getName())
.to("activemq:queue:bar");
}
}
My Camel context look as following:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:camel="http://camel.apache.org/schema/spring"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://camel.apache.org/schema/spring
http://camel.apache.org/schema/spring/camel-spring.xsd">
<bean id="route1" class="org.apache.cmueller.test.Route1" />
<bean id="route2" class="org.apache.cmueller.test.Route2" />
<bean id="activemq"
class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="connectionFactory" ref="connectionFactory" />
</bean>
<bean id="connectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory">
<constructor-arg
value="vm://localhost?broker.persistent=false&broker.useJmx=false"/>
</bean>
<camel:camelContext trace="true">
<camel:routeBuilder ref="route1" />
<camel:routeBuilder ref="route2" />
</camel:camelContext>
</beans>
I would like to test my Route1 implementation in isolation (without Route2).
Because of this, I need to stop Route2. But it doesn't work for my with the
following code:
public class Route1Test extends CamelSpringTestSupport {
@EndpointInject(uri = "mock:foo")
private MockEndpoint mockEndpointFoo;
@Override
@Before
public void setUp() throws Exception {
super.setUp();
DefaultRoute route2 = (DefaultRoute)
context.getRoute(Route2.class.getName());
route2.stop();
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("activemq:queue:foo")
.to(mockEndpointFoo);
}
});
}
@Test
public void test() throws Exception {
mockEndpointFoo.expectedBodiesReceived("1", "2", "3", "4", "5", "6",
"7", "8", "9", "0");
mockEndpointFoo.assertIsSatisfied();
}
@Override
protected AbstractApplicationContext createApplicationContext() {
return new
ClassPathXmlApplicationContext("META-INF/spring/bundle-context.xml");
}
}
Does have anybody an idea what I did wrong?
I attached my Eclipse sample project for convenience.
Best,
Christian
Re: Stop a route for unit testing
Posted by Willem Jiang <wi...@gmail.com>.
I filled a JIRA[1] and committed a patch to address the issue that
CamelContext.stopRoute(routeId) removes the route from CamelContext.
On 12/12/11 7:09 AM, Christian Müller wrote:
> Hello Willem!
>
> I attached a patch with two unit tests which both fail. Could you please
> check whether the test is wrong or if it's a bug.
>
> Thanks in advance,
> Christian
--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang
Re: Stop a route for unit testing
Posted by Christian Müller <ch...@gmail.com>.
Thanks Willem to work on this and got this fixed.
Best,
Christian
On Sun, Dec 18, 2011 at 1:56 AM, Willem Jiang <wi...@gmail.com>wrote:
> I filled a JIRA[1] and committed a patch to address the issue that
> CamelContext.stopRoute(**routeId) removes the route from CamelContext.
>
> [1]https://issues.apache.org/**jira/browse/CAMEL-4790<https://issues.apache.org/jira/browse/CAMEL-4790>
>
>
> On 12/12/11 7:09 AM, Christian Müller wrote:
>
>> Hello Willem!
>>
>> I attached a patch with two unit tests which both fail. Could you please
>> check whether the test is wrong or if it's a bug.
>>
>> Thanks in advance,
>> Christian
>>
>
>
> --
> Willem
> ------------------------------**----
> FuseSource
> Web: http://www.fusesource.com
> Blog: http://willemjiang.blogspot.**com<http://willemjiang.blogspot.com>(English)
> http://jnn.javaeye.com (Chinese)
> Twitter: willemjiang
> Weibo: willemjiang
>
Re: Stop a route for unit testing
Posted by Willem Jiang <wi...@gmail.com>.
I filled a JIRA[1] and committed a patch to address the issue that
CamelContext.stopRoute(routeId) removes the route from CamelContext.
[1]https://issues.apache.org/jira/browse/CAMEL-4790
On 12/12/11 7:09 AM, Christian Müller wrote:
> Hello Willem!
>
> I attached a patch with two unit tests which both fail. Could you please
> check whether the test is wrong or if it's a bug.
>
> Thanks in advance,
> Christian
--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang
Re: Stop a route for unit testing
Posted by Willem Jiang <wi...@gmail.com>.
Hi Christian,
I didn't see the patch from your mail. Can you resend it ?
On Mon Dec 12 07:09:07 2011, Christian Müller wrote:
> Hello Willem!
>
> I attached a patch with two unit tests which both fail. Could you
> please check whether the test is wrong or if it's a bug.
>
> Thanks in advance,
> Christian
--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang
Re: Stop a route for unit testing
Posted by Christian Müller <ch...@gmail.com>.
Hello Willem!
I attached a patch with two unit tests which both fail. Could you please
check whether the test is wrong or if it's a bug.
Thanks in advance,
Christian
Re: Stop a route for unit testing
Posted by Christian Müller <ch...@gmail.com>.
Hello Willem, hello list!
Today I found a bit time to look again into this issue and I could solve it
(will provide a unit test later for this).
The trick was to use
context.stopRoute(routeId);
instead of
((DefaultRoute) context.getRoute(routeId)).stop(); // doesn't work
Also
context.removeRoute(routeId);
only removes the route, if the routeStatus is already "stopped" (which was
not the case in my unit test because the route was started automaticly).
Best,
Christian
On Thu, Aug 25, 2011 at 3:46 AM, Willem Jiang <wi...@gmail.com>wrote:
> Hi Christian,
>
> It looks like the route2 doesn't be shutdown, so your mock endpoint only
> get 5 messages.
>
> Here is the setup code snippet which is the only change in the test code.
>
>
> @Override
> @Before
> public void setUp() throws Exception {
> super.setUp();
>
> //DefaultRoute route2 = (DefaultRoute)
> context.getRoute(Route2.class.**getName());
> //route2.stop();
>
> context.removeRoute(Route2.**class.getName());
>
> context.addRoutes(new RouteBuilder() {
> @Override
> public void configure() throws Exception {
> from("activemq:queue:foo")
> .to(mockEndpointFoo);
> }
> });
> }
>
>
>
> On 8/25/11 12:29 AM, Christian Müller wrote:
>
>> Hello Willem!
>>
>> Today, I tested it again with 2.8.0 and 2.9-SNAPSHOT (log attached at the
>> end of this mail) and my test still fails. Any ideas what's going wrong?
>>
>> My env:
>> Java version: 1.6.0_26, vendor: Apple Inc.
>> Java home: /System/Library/Java/**JavaVirtualMachines/1.6.0.jdk/**
>> Contents/Home
>> Default locale: en_US, platform encoding: MacRoman
>> OS name: "mac os x", version: "10.7.1", arch: "x86_64", family: "mac"
>> Processor: 3.06 GHz Intel Core 2 Duo
>>
>> Best,
>> Christian
>>
>>
>
> --
> Willem
> ------------------------------**----
> FuseSource
> Web: http://www.fusesource.com
> Blog: http://willemjiang.blogspot.**com<http://willemjiang.blogspot.com>(English)
> http://jnn.javaeye.com (Chinese)
> Twitter: willemjiang
> Weibo: willemjiang
>
Re: Stop a route for unit testing
Posted by Willem Jiang <wi...@gmail.com>.
Hi Christian,
It looks like the route2 doesn't be shutdown, so your mock endpoint only
get 5 messages.
Here is the setup code snippet which is the only change in the test code.
@Override
@Before
public void setUp() throws Exception {
super.setUp();
//DefaultRoute route2 = (DefaultRoute)
context.getRoute(Route2.class.getName());
//route2.stop();
context.removeRoute(Route2.class.getName());
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("activemq:queue:foo")
.to(mockEndpointFoo);
}
});
}
On 8/25/11 12:29 AM, Christian Müller wrote:
> Hello Willem!
>
> Today, I tested it again with 2.8.0 and 2.9-SNAPSHOT (log attached at the
> end of this mail) and my test still fails. Any ideas what's going wrong?
>
> My env:
> Java version: 1.6.0_26, vendor: Apple Inc.
> Java home: /System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home
> Default locale: en_US, platform encoding: MacRoman
> OS name: "mac os x", version: "10.7.1", arch: "x86_64", family: "mac"
> Processor: 3.06 GHz Intel Core 2 Duo
>
> Best,
> Christian
>
--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang
Re: Stop a route for unit testing
Posted by Christian Müller <ch...@gmail.com>.
Hello Willem!
Today, I tested it again with 2.8.0 and 2.9-SNAPSHOT (log attached at the
end of this mail) and my test still fails. Any ideas what's going wrong?
My env:
Java version: 1.6.0_26, vendor: Apple Inc.
Java home: /System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home
Default locale: en_US, platform encoding: MacRoman
OS name: "mac os x", version: "10.7.1", arch: "x86_64", family: "mac"
Processor: 3.06 GHz Intel Core 2 Duo
Best,
Christian
2011-08-24 18:22:25,245 [main ] INFO
Route1Test -
********************************************************************************
2011-08-24 18:22:25,246 [main ] INFO
Route1Test - Testing:
test(org.apache.cmueller.test.Route1Test)
2011-08-24 18:22:25,246 [main ] INFO
Route1Test -
********************************************************************************
2011-08-24 18:22:25,461 [main ] INFO
GenericApplicationContext - Refreshing
org.springframework.context.support.GenericApplicationContext@571a75a2:
startup date [Wed Aug 24 18:22:25 CEST 2011]; root of context hierarchy
2011-08-24 18:22:25,489 [main ] INFO
DefaultListableBeanFactory - Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@31b5998f:
defining beans [excludingResolver]; root of factory hierarchy
2011-08-24 18:22:25,565 [main ] INFO
ClassPathXmlApplicationContext - Refreshing
org.springframework.context.support.ClassPathXmlApplicationContext@5af6ac0b:
startup date [Wed Aug 24 18:22:25 CEST 2011]; parent:
org.springframework.context.support.GenericApplicationContext@571a75a2
2011-08-24 18:22:25,594 [main ] INFO
XmlBeanDefinitionReader - Loading XML bean definitions from class
path resource [META-INF/spring/bundle-context.xml]
2011-08-24 18:22:26,098 [main ] INFO
CamelNamespaceHandler - OSGi environment not detected.
2011-08-24 18:22:26,100 [main ] DEBUG
CamelNamespaceHandler - Using
org.apache.camel.spring.CamelContextFactoryBean as
CamelContextBeanDefinitionParser
2011-08-24 18:22:27,139 [main ] DEBUG
CamelNamespaceHandler - Registered default:
org.apache.camel.spring.CamelProducerTemplateFactoryBean with id: template
on camel context: camel
2011-08-24 18:22:27,139 [main ] DEBUG
CamelNamespaceHandler - Registered default:
org.apache.camel.spring.CamelConsumerTemplateFactoryBean with id:
consumerTemplate on camel context: camel
2011-08-24 18:22:27,178 [main ] INFO
DefaultListableBeanFactory - Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@49f10a67:
defining beans
[route1,route2,activemq,connectionFactory,template,consumerTemplate,camel:beanPostProcessor,camel];
parent:
org.springframework.beans.factory.support.DefaultListableBeanFactory@31b5998f
2011-08-24 18:22:27,214 [main ] INFO
bstractCamelContextFactoryBean - Using custom PackageScanClassResolver:
org.apache.camel.test.junit4.CamelSpringTestSupport$ExcludingPackageScanClassResolver@7befc208
2011-08-24 18:22:27,336 [main ] DEBUG
SpringCamelContext - Set the application context classloader to:
sun.misc.Launcher$AppClassLoader@40affc70
2011-08-24 18:22:27,343 [main ] DEBUG
bstractCamelContextFactoryBean - Found JAXB created routes: []
2011-08-24 18:22:27,369 [main ] DEBUG
SpringCamelContext - Adding routes from builder: Routes: []
2011-08-24 18:22:27,377 [main ] DEBUG
SpringCamelContext - Adding routes from builder: Routes: []
2011-08-24 18:22:27,463 [main ] DEBUG
SpringCamelContext - onApplicationEvent:
org.springframework.context.event.ContextRefreshedEvent[source=org.springframework.context.support.ClassPathXmlApplicationContext@5af6ac0b:
startup date [Wed Aug 24 18:22:25 CEST 2011]; parent:
org.springframework.context.support.GenericApplicationContext@571a75a2]
2011-08-24 18:22:27,463 [main ] INFO
SpringCamelContext - No spring-event endpoint enabled to handle
event:
org.springframework.context.event.ContextRefreshedEvent[source=org.springframework.context.support.ClassPathXmlApplicationContext@5af6ac0b:
startup date [Wed Aug 24 18:22:25 CEST 2011]; parent:
org.springframework.context.support.GenericApplicationContext@571a75a2]
2011-08-24 18:22:27,469 [main ] DEBUG
SharedProducerServicePool - Starting service pool:
org.apache.camel.impl.SharedProducerServicePool@22c28cb7
2011-08-24 18:22:27,476 [main ] DEBUG
DefaultComponentResolver - Found component: mock in registry: null
2011-08-24 18:22:27,480 [main ] DEBUG
DefaultComponentResolver - Found component: mock via type:
org.apache.camel.component.mock.MockComponent via:
META-INF/services/org/apache/camel/component/mock
2011-08-24 18:22:27,481 [main ] DEBUG
DefaultComponent - Creating endpoint uri=[mock://foo],
path=[foo], parameters=[{}]
2011-08-24 18:22:27,490 [main ] DEBUG
SpringCamelContext - mock://foo converted to endpoint:
Endpoint[mock://foo] by component:
org.apache.camel.component.mock.MockComponent@393e6226
2011-08-24 18:22:27,493 [main ] DEBUG
SpringCamelContext - Adding routes from builder: Routes: []
2011-08-24 18:22:27,493 [main ] INFO
SpringCamelContext - Apache Camel 2.9-SNAPSHOT (CamelContext:
camel) is starting
2011-08-24 18:22:27,493 [main ] INFO
SpringCamelContext - Tracing is enabled on CamelContext: camel
2011-08-24 18:22:27,493 [main ] INFO
SpringCamelContext - JMX is disabled. Using
DefaultManagementStrategy.
2011-08-24 18:22:27,522 [main ] INFO
AnnotationTypeConverterLoader - Found 3 packages with 15 @Converter classes
to load
2011-08-24 18:22:27,580 [main ] INFO
DefaultTypeConverter - Loaded 156 core type converters (total 156
type converters)
2011-08-24 18:22:27,581 [main ] DEBUG
DefaultTypeConverter - Loading additional type converters ...
2011-08-24 18:22:27,581 [main ] DEBUG
AnnotationTypeConverterLoader - Loading file
META-INF/services/org/apache/camel/TypeConverter to retrieve list of
packages, from url:
file:/Users/cmueller/workspaceApacheGitSVN/camel/camel-core/target/classes/META-INF/services/org/apache/camel/TypeConverter
2011-08-24 18:22:27,582 [main ] DEBUG
AnnotationTypeConverterLoader - Loading file
META-INF/services/org/apache/camel/TypeConverter to retrieve list of
packages, from url:
jar:file:/Users/cmueller/.m2/repository/org/apache/activemq/activemq-camel/5.5.0/activemq-camel-5.5.0.jar!/META-INF/services/org/apache/camel/TypeConverter
2011-08-24 18:22:27,583 [main ] DEBUG
ludingPackageScanClassResolver - Searching for annotations of
org.apache.camel.Converter in packages:
[org.apache.activemq.camel.converter]
2011-08-24 18:22:27,591 [main ] DEBUG
ludingPackageScanClassResolver - Found: [class
org.apache.activemq.camel.converter.ActiveMQConverter, class
org.apache.activemq.camel.converter.ActiveMQMessageConverter]
2011-08-24 18:22:27,591 [main ] INFO
AnnotationTypeConverterLoader - Found 1 packages with 2 @Converter classes
to load
2011-08-24 18:22:27,599 [main ] DEBUG
DefaultTypeConverter - Loading additional type converters done
2011-08-24 18:22:27,603 [main ] INFO
DefaultTypeConverter - Loaded additional 3 type converters (total
159 type converters) in 0.018 seconds
2011-08-24 18:22:27,606 [main ] DEBUG
DefaultComponentResolver - Found component: file in registry: null
2011-08-24 18:22:27,608 [main ] DEBUG
DefaultComponentResolver - Found component: file via type:
org.apache.camel.component.file.FileComponent via:
META-INF/services/org/apache/camel/component/file
2011-08-24 18:22:27,613 [main ] DEBUG
DefaultComponent - Creating endpoint
uri=[file://src/test/data?initialDelay=5000&noop=true],
path=[src/test/data], parameters=[{initialDelay=5000, noop=true}]
2011-08-24 18:22:27,631 [main ] DEBUG
SpringCamelContext -
file://src/test/data?initialDelay=5000&noop=true converted to endpoint:
Endpoint[file://src/test/data?initialDelay=5000&noop=true] by component:
org.apache.camel.component.file.FileComponent@5d17c0eb
2011-08-24 18:22:27,668 [main ] DEBUG
DefaultComponentResolver - Found component: activemq in registry:
org.apache.activemq.camel.component.ActiveMQComponent@4b8bbb61
2011-08-24 18:22:27,668 [main ] DEBUG
DefaultComponent - Creating endpoint
uri=[activemq://queue:foo], path=[queue:foo], parameters=[{}]
2011-08-24 18:22:27,671 [main ] DEBUG
SpringCamelContext - activemq://queue:foo converted to endpoint:
Endpoint[activemq://queue:foo] by component:
org.apache.activemq.camel.component.ActiveMQComponent@4b8bbb61
2011-08-24 18:22:27,689 [main ] DEBUG
DefaultChannel - Initialize channel for target:
'To[activemq:queue:foo]'
2011-08-24 18:22:27,712 [main ] DEBUG
DefaultChannel - Initialize channel for target:
'Split[{tokenize(body, ,)} -> [To[activemq:queue:foo]]]'
2011-08-24 18:22:27,727 [main ] DEBUG
DefaultComponent - Creating endpoint
uri=[activemq://queue:bar], path=[queue:bar], parameters=[{}]
2011-08-24 18:22:27,727 [main ] DEBUG
SpringCamelContext - activemq://queue:bar converted to endpoint:
Endpoint[activemq://queue:bar] by component:
org.apache.activemq.camel.component.ActiveMQComponent@4b8bbb61
2011-08-24 18:22:27,728 [main ] DEBUG
DefaultChannel - Initialize channel for target:
'To[activemq:queue:bar]'
2011-08-24 18:22:27,738 [main ] DEBUG
SpringCamelContext - Warming up route id:
org.apache.cmueller.test.Route1 having autoStartup=true
2011-08-24 18:22:27,738 [main ] DEBUG
RouteService - Starting services on route:
org.apache.cmueller.test.Route1
2011-08-24 18:22:27,743 [main ] DEBUG
DefaultExecutorServiceManager - Created new ScheduledThreadPool for source:
Consumer[file://src/test/data?initialDelay=5000&noop=true] with name:
file://src/test/data?initialDelay=5000&noop=true. ->
java.util.concurrent.ScheduledThreadPoolExecutor@4d74f02c
2011-08-24 18:22:27,743 [main ] INFO
FileEndpoint - Endpoint is configured with noop=true so
forcing endpoint to be idempotent as well
2011-08-24 18:22:27,743 [main ] INFO
FileEndpoint - Using default memory based idempotent
repository with cache max size: 1000
2011-08-24 18:22:27,745 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route1 ->
Instrumentation:route[UnitOfWork(Channel[Splitter[on: tokenize(body, ,) to:
Channel[sendTo(Endpoint[activemq://queue:foo])] aggregate: null]])]
2011-08-24 18:22:27,754 [main ] DEBUG
JmsProducer - Starting producer:
Producer[activemq://queue:foo]
2011-08-24 18:22:27,754 [main ] DEBUG
ProducerCache - Adding to producer cache with key:
Endpoint[activemq://queue:foo] for producer: Producer[activemq://queue:foo]
2011-08-24 18:22:27,755 [main ] DEBUG
DefaultExecutorServiceManager - Created new ScheduledThreadPool for source:
DefaultErrorHandler[TraceInterceptor[To[activemq:queue:foo]]] with name:
ErrorHandlerRedeliveryTask. ->
java.util.concurrent.ScheduledThreadPoolExecutor@41a7c484
2011-08-24 18:22:27,755 [main ] DEBUG
DefaultErrorHandler - Redelivery enabled: false on error handler:
DefaultErrorHandler[TraceInterceptor[To[activemq:queue:foo]]]
2011-08-24 18:22:27,755 [main ] DEBUG
DefaultErrorHandler - Redelivery enabled: false on error handler:
DefaultErrorHandler[TraceInterceptor[Split[{tokenize(body, ,)} ->
[To[activemq:queue:foo]]]]]
2011-08-24 18:22:27,761 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route1 -> UnitOfWork(Channel[Splitter[on:
tokenize(body, ,) to: Channel[sendTo(Endpoint[activemq://queue:foo])]
aggregate: null]])
2011-08-24 18:22:27,761 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route1 -> Channel[Splitter[on: tokenize(body, ,)
to: Channel[sendTo(Endpoint[activemq://queue:foo])] aggregate: null]]
2011-08-24 18:22:27,761 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route1 -> Splitter[on: tokenize(body, ,) to:
Channel[sendTo(Endpoint[activemq://queue:foo])] aggregate: null]
2011-08-24 18:22:27,762 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route1 ->
Channel[sendTo(Endpoint[activemq://queue:foo])]
2011-08-24 18:22:27,762 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route1 -> sendTo(Endpoint[activemq://queue:foo])
2011-08-24 18:22:27,762 [main ] DEBUG
SpringCamelContext - Warming up route id:
org.apache.cmueller.test.Route2 having autoStartup=true
2011-08-24 18:22:27,762 [main ] DEBUG
RouteService - Starting services on route:
org.apache.cmueller.test.Route2
2011-08-24 18:22:27,787 [main ] DEBUG
DefaultExecutorServiceManager - Created new CachedThreadPool for source:
Consumer[activemq://queue:foo] with name: JmsConsumer[foo]. ->
java.util.concurrent.ThreadPoolExecutor@11b9d4d8
2011-08-24 18:22:27,787 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route2 ->
Instrumentation:route[UnitOfWork(Channel[sendTo(Endpoint[activemq://queue:bar])])]
2011-08-24 18:22:27,788 [main ] DEBUG
JmsProducer - Starting producer:
Producer[activemq://queue:bar]
2011-08-24 18:22:27,788 [main ] DEBUG
ProducerCache - Adding to producer cache with key:
Endpoint[activemq://queue:bar] for producer: Producer[activemq://queue:bar]
2011-08-24 18:22:27,788 [main ] DEBUG
DefaultErrorHandler - Redelivery enabled: false on error handler:
DefaultErrorHandler[TraceInterceptor[To[activemq:queue:bar]]]
2011-08-24 18:22:27,788 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route2 ->
UnitOfWork(Channel[sendTo(Endpoint[activemq://queue:bar])])
2011-08-24 18:22:27,788 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route2 ->
Channel[sendTo(Endpoint[activemq://queue:bar])]
2011-08-24 18:22:27,788 [main ] DEBUG
RouteService - Starting child service on route:
org.apache.cmueller.test.Route2 -> sendTo(Endpoint[activemq://queue:bar])
2011-08-24 18:22:27,789 [main ] DEBUG
SpringCamelContext - Route: org.apache.cmueller.test.Route1 >>>
EventDrivenConsumerRoute[Endpoint[file://src/test/data?initialDelay=5000&noop=true]
-> Instrumentation:route[UnitOfWork(Channel[Splitter[on: tokenize(body, ,)
to: Channel[sendTo(Endpoint[activemq://queue:foo])] aggregate: null]])]]
2011-08-24 18:22:27,789 [main ] DEBUG
SpringCamelContext - Starting consumer (order: 1000) on route:
org.apache.cmueller.test.Route1
2011-08-24 18:22:27,789 [main ] DEBUG
FileConsumer - Starting consumer:
Consumer[file://src/test/data?initialDelay=5000&noop=true]
2011-08-24 18:22:27,789 [main ] DEBUG
ScheduledPollConsumer - Scheduling poll (fixed delay) with
initialDelay: 5000, delay: 500 (milliseconds) for:
Endpoint[file://src/test/data?initialDelay=5000&noop=true]
2011-08-24 18:22:27,793 [main ] DEBUG
FileEndpoint - Parameters for Generic file process
strategy {readLock=markerFile, noop=true, readLockTimeout=10000,
readLockCheckInterval=1000}
2011-08-24 18:22:27,802 [main ] DEBUG
FileEndpoint - Using Generic file process strategy:
org.apache.camel.component.file.strategy.GenericFileRenameProcessStrategy@2f7fc44f
2011-08-24 18:22:27,802 [main ] DEBUG
rFileExclusiveReadLockStrategy - Prepare on startup by deleting orphaned
lock files from: src/test/data
2011-08-24 18:22:27,803 [main ] INFO
SpringCamelContext - Route: org.apache.cmueller.test.Route1
started and consuming from:
Endpoint[file://src/test/data?initialDelay=5000&noop=true]
2011-08-24 18:22:27,803 [main ] DEBUG
SpringCamelContext - Route: org.apache.cmueller.test.Route2 >>>
EventDrivenConsumerRoute[Endpoint[activemq://queue:foo] ->
Instrumentation:route[UnitOfWork(Channel[sendTo(Endpoint[activemq://queue:bar])])]]
2011-08-24 18:22:27,803 [main ] DEBUG
SpringCamelContext - Starting consumer (order: 1001) on route:
org.apache.cmueller.test.Route2
2011-08-24 18:22:27,803 [main ] DEBUG
JmsConsumer - Starting consumer:
Consumer[activemq://queue:foo]
2011-08-24 18:22:27,942 [main ] INFO
BrokerService - Using Persistence Adapter:
MemoryPersistenceAdapter
2011-08-24 18:22:27,943 [main ] INFO
BrokerService - ActiveMQ 5.5.0 JMS Message Broker
(localhost) is starting
2011-08-24 18:22:27,943 [main ] INFO
BrokerService - For help or more information please see:
http://activemq.apache.org/
2011-08-24 18:22:28,078 [main ] INFO
BrokerService - ActiveMQ JMS Message Broker (localhost,
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-0:1) started
2011-08-24 18:22:28,082 [main ] INFO
TransportConnector - Connector vm://localhost Started
2011-08-24 18:22:28,098 [main ] DEBUG
JmsMessageListenerContainer - Established shared JMS Connection
2011-08-24 18:22:28,098 [main ] DEBUG
JmsMessageListenerContainer - Resumed paused task:
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker@1ca37c6a
2011-08-24 18:22:28,135 [main ] INFO
SpringCamelContext - Route: org.apache.cmueller.test.Route2
started and consuming from: Endpoint[activemq://queue:foo]
2011-08-24 18:22:28,138 [main ] DEBUG
DefaultComponent - Creating endpoint
uri=[spring-event://default], path=[default], parameters=[{}]
2011-08-24 18:22:28,139 [main ] DEBUG
SpringCamelContext - spring-event://default converted to
endpoint: Endpoint[spring-event://default] by component:
org.apache.camel.component.event.EventComponent@50f800db
2011-08-24 18:22:28,139 [main ] INFO
SpringCamelContext - Total 2 routes, of which 2 is started.
2011-08-24 18:22:28,139 [main ] INFO
SpringCamelContext - Apache Camel 2.9-SNAPSHOT (CamelContext:
camel) started in 0.646 seconds
2011-08-24 18:22:28,141 [main ] DEBUG
SpringCamelContext - Adding routes from builder: Routes: []
2011-08-24 18:22:28,157 [main ] DEBUG
DefaultChannel - Initialize channel for target:
'To[mock://foo]'
2011-08-24 18:22:28,158 [main ] DEBUG
SpringCamelContext - Warming up route id: route1 having
autoStartup=true
2011-08-24 18:22:28,158 [main ] DEBUG
RouteService - Starting services on route: route1
2011-08-24 18:22:28,158 [main ] DEBUG
DefaultExecutorServiceManager - Created new CachedThreadPool for source:
Consumer[activemq://queue:foo] with name: JmsConsumer[foo]. ->
java.util.concurrent.ThreadPoolExecutor@3c992fa5
2011-08-24 18:22:28,158 [main ] DEBUG
RouteService - Starting child service on route: route1 ->
Instrumentation:route[UnitOfWork(Channel[sendTo(Endpoint[mock://foo])])]
2011-08-24 18:22:28,163 [main ] DEBUG
MockEndpoint$1 - Starting producer: Producer[mock://foo]
2011-08-24 18:22:28,163 [main ] DEBUG
ProducerCache - Adding to producer cache with key:
Endpoint[mock://foo] for producer: Producer[mock://foo]
2011-08-24 18:22:28,163 [main ] DEBUG
DefaultErrorHandler - Redelivery enabled: false on error handler:
DefaultErrorHandler[TraceInterceptor[To[mock://foo]]]
2011-08-24 18:22:28,163 [main ] DEBUG
RouteService - Starting child service on route: route1 ->
UnitOfWork(Channel[sendTo(Endpoint[mock://foo])])
2011-08-24 18:22:28,163 [main ] DEBUG
RouteService - Starting child service on route: route1 ->
Channel[sendTo(Endpoint[mock://foo])]
2011-08-24 18:22:28,163 [main ] DEBUG
RouteService - Starting child service on route: route1 ->
sendTo(Endpoint[mock://foo])
2011-08-24 18:22:28,164 [main ] DEBUG
SpringCamelContext - Route: route1 >>>
EventDrivenConsumerRoute[Endpoint[activemq://queue:foo] ->
Instrumentation:route[UnitOfWork(Channel[sendTo(Endpoint[mock://foo])])]]
2011-08-24 18:22:28,164 [main ] DEBUG
SpringCamelContext - Starting consumer (order: 1002) on route:
route1
2011-08-24 18:22:28,164 [main ] DEBUG
JmsConsumer - Starting consumer:
Consumer[activemq://queue:foo]
2011-08-24 18:22:28,164 [main ] DEBUG
JmsMessageListenerContainer - Established shared JMS Connection
2011-08-24 18:22:28,198 [main ] DEBUG
JmsMessageListenerContainer - Resumed paused task:
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker@2c92af24
2011-08-24 18:22:28,199 [main ] INFO
SpringCamelContext - Route: route1 started and consuming from:
Endpoint[activemq://queue:foo]
2011-08-24 18:22:28,201 [main ] INFO
MockEndpoint - Asserting: Endpoint[mock://foo] is
satisfied
2011-08-24 18:22:28,201 [main ] DEBUG
MockEndpoint - Waiting on the latch for: 0 millis
2011-08-24 18:22:32,792 [//src/test/data] DEBUG
FileConsumer - Took 0.002 seconds to poll: src/test/data
2011-08-24 18:22:32,798 [//src/test/data] DEBUG
FileConsumer - Total 1 files to consume
2011-08-24 18:22:32,799 [//src/test/data] DEBUG
FileConsumer - About to process file:
GenericFile[test.txt] using exchange: Exchange[test.txt]
2011-08-24 18:22:32,810 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-1 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
split[tokenize(body, ,)] <<< Pattern:InOnly,
Headers:{CamelFilePath=src/test/data/test.txt,
CamelFileRelativePath=test.txt, CamelFileAbsolute=false,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileName=test.txt, CamelFileNameOnly=test.txt, CamelFileLength=19,
CamelFileParent=src/test/data, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011}, BodyType:org.apache.camel.component.file.GenericFile, Body:[Body
is file based: GenericFile[test.txt]]
2011-08-24 18:22:32,828 [//src/test/data] DEBUG
DefaultErrorHandler - Redelivery enabled: false on error handler:
DefaultErrorHandler[Channel[sendTo(Endpoint[activemq://queue:foo])]]
2011-08-24 18:22:32,854 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-3 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileParent=src/test/data, CamelFileName=test.txt,
CamelFileAbsolute=false, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileNameOnly=test.txt}, BodyType:String, Body:1
2011-08-24 18:22:32,857 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 1]
2011-08-24 18:22:32,861 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,871 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 1}
2011-08-24 18:22:32,884 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-4 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileNameOnly=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileName=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolute=false, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileRelativePath=test.txt, CamelFileLength=19}, BodyType:String, Body:2
2011-08-24 18:22:32,884 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 2]
2011-08-24 18:22:32,885 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,885 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 2}
2011-08-24 18:22:32,888 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2,started=true}
}]
2011-08-24 18:22:32,888 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}]
2011-08-24 18:22:32,906 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-5 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFilePath=src/test/data/test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileParent=src/test/data,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt, CamelFileLength=19,
CamelFileNameOnly=test.txt, CamelFileAbsolute=false}, BodyType:String,
Body:3
2011-08-24 18:22:32,907 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 3]
2011-08-24 18:22:32,907 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,908 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 3}
2011-08-24 18:22:32,909 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-6 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFilePath=src/test/data/test.txt, CamelFileAbsolute=false,
CamelFileNameOnly=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileRelativePath=test.txt, CamelFileLength=19,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileParent=src/test/data}, BodyType:String,
Body:4
2011-08-24 18:22:32,909 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 4]
2011-08-24 18:22:32,910 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,910 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 4}
2011-08-24 18:22:32,912 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-7 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileParent=src/test/data, CamelFileLength=19,
CamelFileRelativePath=test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileNameOnly=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, CamelFilePath=src/test/data/test.txt, CamelFileName=test.txt,
CamelFileAbsolute=false}, BodyType:String, Body:5
2011-08-24 18:22:32,913 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 5]
2011-08-24 18:22:32,913 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,913 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 5}
2011-08-24 18:22:32,915 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-8 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileNameOnly=test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileRelativePath=test.txt, CamelFileAbsolute=false,
CamelFileName=test.txt, CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, CamelFileLength=19},
BodyType:String, Body:6
2011-08-24 18:22:32,915 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 6]
2011-08-24 18:22:32,915 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,917 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 6}
2011-08-24 18:22:32,919 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-9 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFilePath=src/test/data/test.txt, CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileRelativePath=test.txt, CamelFileLength=19, CamelFileName=test.txt,
CamelFileAbsolute=false, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2},
BodyType:String, Body:7
2011-08-24 18:22:32,923 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 7]
2011-08-24 18:22:32,923 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,924 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 7}
2011-08-24 18:22:32,925 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-10 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileNameOnly=test.txt, CamelFileName=test.txt, CamelFileAbsolute=false,
CamelFileRelativePath=test.txt, CamelFileLength=19,
CamelFileParent=src/test/data, CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt},
BodyType:String, Body:8
2011-08-24 18:22:32,926 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 8]
2011-08-24 18:22:32,926 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,926 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 8}
2011-08-24 18:22:32,927 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-11 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileRelativePath=test.txt, CamelFileName=test.txt,
CamelFileNameOnly=test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileAbsolute=false,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, CamelFileLength=19,
CamelFileParent=src/test/data}, BodyType:String, Body:9
2011-08-24 18:22:32,928 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 9]
2011-08-24 18:22:32,928 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,928 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 9}
2011-08-24 18:22:32,931 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 10, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952886, arrival = 0, brokerInTime = 1314202952886, brokerOutTime =
1314202952888, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 2}
2011-08-24 18:22:32,936 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 9, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952878, arrival = 0, brokerInTime = 1314202952878, brokerOutTime =
1314202952883, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 1}
2011-08-24 18:22:32,940 [//src/test/data] INFO
Tracer -
ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-12 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt,
CamelFileLength=19, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFilePath=src/test/data/test.txt, CamelFileName=test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileParent=src/test/data,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileAbsolute=false}, BodyType:String, Body:0
2011-08-24 18:22:32,941 [//src/test/data] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:foo]
Exchange[Message: 0]
2011-08-24 18:22:32,941 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3,started=true}
}
2011-08-24 18:22:32,942 [//src/test/data] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://foo with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = false, type = null,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = false, readOnlyBody = false,
droppable = false, text = 0}
2011-08-24 18:22:32,943 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:1 >>>
(org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly,
Headers:{CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSType=null, JMSCorrelationID=null, CamelFileName=test.txt,
JMSRedelivered=false, CamelFileParent=src/test/data, CamelFileLength=19,
CamelFileNameOnly=test.txt, JMSReplyTo=null, JMSDestination=queue://foo,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:1,
JMSDeliveryMode=2, CamelFilePath=src/test/data/test.txt, JMSPriority=4,
CamelFileRelativePath=test.txt, CamelFileAbsolute=false, JMSXGroupID=null,
JMSExpiration=0,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSTimestamp=1314202952878}, BodyType:String, Body:1
2011-08-24 18:22:32,943 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:2 >>>
(route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{JMSExpiration=0,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSDeliveryMode=2, JMSPriority=4, JMSRedelivered=false,
JMSTimestamp=1314202952886, CamelFileAbsolute=false,
CamelFileNameOnly=test.txt, JMSDestination=queue://foo,
CamelFileName=test.txt, JMSType=null,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFilePath=src/test/data/test.txt, JMSCorrelationID=null,
CamelFileRelativePath=test.txt, JMSXGroupID=null, CamelFileLength=19,
JMSReplyTo=null, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:2,
CamelFileParent=src/test/data}, BodyType:String, Body:2
2011-08-24 18:22:32,943 [//src/test/data] DEBUG
MulticastProcessor - Done sequential processing 10 exchanges
2011-08-24 18:22:32,945 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[mock://foo]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 10, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952886, arrival = 0, brokerInTime = 1314202952886, brokerOutTime =
1314202952888, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 2}]
2011-08-24 18:22:32,945 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:bar]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 9, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:1,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952878, arrival = 0, brokerInTime = 1314202952878, brokerOutTime =
1314202952883, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 1}]
2011-08-24 18:22:32,946 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}
2011-08-24 18:22:32,946 [msConsumer[foo]] DEBUG
MockEndpoint - mock://foo >>>> 0 : Exchange[JmsMessage:
ActiveMQTextMessage {commandId = 10, responseRequired = true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952886, arrival = 0, brokerInTime = 1314202952886, brokerOutTime =
1314202952888, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 2}] with body: 2 and
headers:{CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSExpiration=0, CamelFileLength=19, JMSDestination=queue://foo,
JMSType=null, JMSXGroupID=null, JMSCorrelationID=null,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileNameOnly=test.txt, CamelFileAbsolute=false,
CamelFileRelativePath=test.txt, CamelFilePath=src/test/data/test.txt,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:2,
JMSRedelivered=false, JMSReplyTo=null, JMSDeliveryMode=2, JMSPriority=4,
CamelFileName=test.txt, JMSTimestamp=1314202952886,
CamelFileParent=src/test/data}
2011-08-24 18:22:32,947 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2,started=true}
}]
2011-08-24 18:22:32,947 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 14, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:4,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952911, arrival = 0, brokerInTime = 1314202952911, brokerOutTime =
1314202952911, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 4}
2011-08-24 18:22:32,945 [//src/test/data] DEBUG
GenericFileOnCompletion - Done processing file: GenericFile[test.txt]
using exchange: Exchange[test.txt]
2011-08-24 18:22:32,952 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:4 >>>
(route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{JMSExpiration=0, JMSDestination=queue://foo,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSXGroupID=null, JMSCorrelationID=null, CamelFileLength=19,
CamelFileRelativePath=test.txt, JMSTimestamp=1314202952911,
CamelFileParent=src/test/data, JMSPriority=4,
CamelFilePath=src/test/data/test.txt, CamelFileLastModified=Mon Aug 22
20:03:56 CEST 2011, CamelFileAbsolute=false, JMSType=null, JMSReplyTo=null,
JMSDeliveryMode=2,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSRedelivered=false, CamelFileNameOnly=test.txt,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:4,
CamelFileName=test.txt}, BodyType:String, Body:4
2011-08-24 18:22:32,947 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://bar with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelJmsDeliveryMode=2, CamelFileAbsolute=false}, readOnlyProperties =
false, readOnlyBody = false, droppable = false, text = 1}
2011-08-24 18:22:32,953 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[mock://foo]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 14, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:4,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952911, arrival = 0, brokerInTime = 1314202952911, brokerOutTime =
1314202952911, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 4}]
2011-08-24 18:22:32,956 [msConsumer[foo]] DEBUG
MockEndpoint - mock://foo >>>> 1 : Exchange[JmsMessage:
ActiveMQTextMessage {commandId = 14, responseRequired = true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:4,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952911, arrival = 0, brokerInTime = 1314202952911, brokerOutTime =
1314202952911, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 4}] with body: 4 and headers:{JMSReplyTo=null,
JMSTimestamp=1314202952911, CamelFileNameOnly=test.txt, JMSExpiration=0,
JMSDestination=queue://foo, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, JMSType=null,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSPriority=4,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:4,
CamelFileAbsolute=false, JMSRedelivered=false, JMSXGroupID=null,
CamelFileLength=19, CamelFileParent=src/test/data,
CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileRelativePath=test.txt, JMSDeliveryMode=2, CamelFileName=test.txt,
JMSCorrelationID=null}
2011-08-24 18:22:32,956 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2,started=true}
}]
2011-08-24 18:22:32,956 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 16, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:6,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952917, arrival = 0, brokerInTime = 1314202952917, brokerOutTime =
1314202952918, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 6}
2011-08-24 18:22:32,957 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:6 >>>
(route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:6,
JMSRedelivered=false, JMSTimestamp=1314202952917,
CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt, JMSPriority=4,
JMSXGroupID=null, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFilePath=src/test/data/test.txt, JMSCorrelationID=null,
JMSExpiration=0, JMSDestination=queue://foo, CamelFileAbsolute=false,
JMSReplyTo=null, JMSType=null, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011, CamelFileName=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, JMSDeliveryMode=2}, BodyType:String, Body:6
2011-08-24 18:22:32,957 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[mock://foo]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 16, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:6,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952917, arrival = 0, brokerInTime = 1314202952917, brokerOutTime =
1314202952918, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 6}]
2011-08-24 18:22:32,958 [msConsumer[foo]] DEBUG
MockEndpoint - mock://foo >>>> 2 : Exchange[JmsMessage:
ActiveMQTextMessage {commandId = 16, responseRequired = true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:6,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952917, arrival = 0, brokerInTime = 1314202952917, brokerOutTime =
1314202952918, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 6}] with body: 6 and
headers:{CamelFileName=test.txt, JMSCorrelationID=null,
CamelFileAbsolute=false, CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSPriority=4, CamelFileLength=19, JMSType=null,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:6,
JMSExpiration=0, CamelFileParent=src/test/data, JMSDeliveryMode=2,
CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt,
JMSXGroupID=null, JMSDestination=queue://foo, JMSRedelivered=false,
JMSTimestamp=1314202952917, JMSReplyTo=null, CamelFileLastModified=Mon Aug
22 20:03:56 CEST 2011}
2011-08-24 18:22:32,958 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2,started=true}
}]
2011-08-24 18:22:32,958 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 18, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:8,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952926, arrival = 0, brokerInTime = 1314202952927, brokerOutTime =
1314202952927, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 8}
2011-08-24 18:22:32,959 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:8 >>>
(route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{JMSDestination=queue://foo, JMSType=null, JMSDeliveryMode=2,
CamelFileLength=19,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileNameOnly=test.txt, JMSXGroupID=null, JMSRedelivered=false,
JMSCorrelationID=null, CamelFileParent=src/test/data,
CamelFilePath=src/test/data/test.txt, CamelFileAbsolute=false,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:8,
JMSExpiration=0, JMSReplyTo=null, CamelFileRelativePath=test.txt,
JMSTimestamp=1314202952926, JMSPriority=4, CamelFileName=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011}, BodyType:String,
Body:8
2011-08-24 18:22:32,959 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[mock://foo]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 18, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:8,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952926, arrival = 0, brokerInTime = 1314202952927, brokerOutTime =
1314202952927, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 8}]
2011-08-24 18:22:32,960 [msConsumer[foo]] DEBUG
MockEndpoint - mock://foo >>>> 3 : Exchange[JmsMessage:
ActiveMQTextMessage {commandId = 18, responseRequired = true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:8,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952926, arrival = 0, brokerInTime = 1314202952927, brokerOutTime =
1314202952927, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 8}] with body: 8 and headers:{JMSReplyTo=null,
CamelFileParent=src/test/data, JMSDeliveryMode=2, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileNameOnly=test.txt,
JMSDestination=queue://foo, JMSRedelivered=false, JMSPriority=4,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSExpiration=0, JMSTimestamp=1314202952926, JMSXGroupID=null, JMSType=null,
CamelFileRelativePath=test.txt, CamelFileLength=19,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSCorrelationID=null, CamelFileAbsolute=false, CamelFileLastModified=Mon
Aug 22 20:03:56 CEST 2011,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:8}
2011-08-24 18:22:32,960 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:2,started=true}
}]
2011-08-24 18:22:32,961 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 20, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:10,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952942, arrival = 0, brokerInTime = 1314202952943, brokerOutTime =
1314202952945, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 0}
2011-08-24 18:22:32,962 [//src/test/data] DEBUG
FileUtil - Retrying attempt 0 to delete file:
/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt.camelLock
2011-08-24 18:22:32,965 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}]
2011-08-24 18:22:32,966 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 13, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:3,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952908, arrival = 0, brokerInTime = 1314202952908, brokerOutTime =
1314202952909, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 3}
2011-08-24 18:22:32,967 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:3 >>>
(org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly,
Headers:{CamelFileNameOnly=test.txt, CamelFileParent=src/test/data,
JMSTimestamp=1314202952908, JMSXGroupID=null, JMSDeliveryMode=2,
JMSPriority=4, CamelFileLength=19, CamelFileRelativePath=test.txt,
JMSRedelivered=false, CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSType=null, JMSExpiration=0,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:3,
CamelFileName=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
JMSReplyTo=null, JMSDestination=queue://foo, JMSCorrelationID=null},
BodyType:String, Body:3
2011-08-24 18:22:32,962 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:10 >>>
(route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{JMSXGroupID=null, JMSType=null, JMSDeliveryMode=2,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSPriority=4, CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileParent=src/test/data, CamelFileName=test.txt,
JMSDestination=queue://foo, CamelFileLength=19,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSRedelivered=false, JMSExpiration=0, CamelFileAbsolute=false,
JMSCorrelationID=null, JMSReplyTo=null, JMSTimestamp=1314202952942,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:10,
CamelFilePath=src/test/data/test.txt}, BodyType:String, Body:0
2011-08-24 18:22:33,002 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:bar]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 13, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:3,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952908, arrival = 0, brokerInTime = 1314202952908, brokerOutTime =
1314202952909, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 3}]
2011-08-24 18:22:33,003 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}
2011-08-24 18:22:33,004 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://bar with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelJmsDeliveryMode=2, CamelFileAbsolute=false}, readOnlyProperties =
false, readOnlyBody = false, droppable = false, text = 3}
2011-08-24 18:22:33,006 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}]
2011-08-24 18:22:33,008 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 15, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:5,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952914, arrival = 0, brokerInTime = 1314202952914, brokerOutTime =
1314202952914, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 5}
2011-08-24 18:22:33,008 [//src/test/data] DEBUG
FileUtil - Tried 1 to delete file:
/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt.camelLock
with result: true
2011-08-24 18:22:33,009 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[mock://foo]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 20, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:10,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952942, arrival = 0, brokerInTime = 1314202952943, brokerOutTime =
1314202952945, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 0}]
2011-08-24 18:22:33,011 [msConsumer[foo]] DEBUG
MockEndpoint - mock://foo >>>> 4 : Exchange[JmsMessage:
ActiveMQTextMessage {commandId = 20, responseRequired = true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:10,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952942, arrival = 0, brokerInTime = 1314202952943, brokerOutTime =
1314202952945, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 0}] with body: 0 and headers:{CamelFileLength=19,
CamelFileName=test.txt, CamelFileRelativePath=test.txt, JMSPriority=4,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, JMSRedelivered=false,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileNameOnly=test.txt, JMSTimestamp=1314202952942,
CamelFileParent=src/test/data, CamelFilePath=src/test/data/test.txt,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:10,
JMSDestination=queue://foo, JMSXGroupID=null, JMSCorrelationID=null,
JMSExpiration=0, JMSReplyTo=null, JMSDeliveryMode=2,
CamelFileAbsolute=false, JMSType=null}
2011-08-24 18:22:33,011 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:5 >>>
(org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly, Headers:{CamelFileLastModified=Mon
Aug 22 20:03:56 CEST 2011, JMSDestination=queue://foo, JMSRedelivered=false,
CamelFileParent=src/test/data,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileNameOnly=test.txt, JMSPriority=4, JMSXGroupID=null,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:5,
CamelFileAbsolute=false, JMSDeliveryMode=2, CamelFileRelativePath=test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSType=null, CamelFilePath=src/test/data/test.txt, CamelFileLength=19,
JMSExpiration=0, JMSTimestamp=1314202952914, JMSReplyTo=null,
JMSCorrelationID=null, CamelFileName=test.txt}, BodyType:String, Body:5
2011-08-24 18:22:33,011 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:bar]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 15, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:5,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952914, arrival = 0, brokerInTime = 1314202952914, brokerOutTime =
1314202952914, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 5}]
2011-08-24 18:22:33,012 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}
2011-08-24 18:22:33,012 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://bar with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelJmsDeliveryMode=2, CamelFileAbsolute=false}, readOnlyProperties =
false, readOnlyBody = false, droppable = false, text = 5}
2011-08-24 18:22:33,012 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}]
2011-08-24 18:22:33,014 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 17, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:7,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952924, arrival = 0, brokerInTime = 1314202952924, brokerOutTime =
1314202952925, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 7}
2011-08-24 18:22:33,015 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:7 >>>
(org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly, Headers:{CamelFileAbsolute=false,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileParent=src/test/data, JMSPriority=4, JMSCorrelationID=null,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:7,
JMSExpiration=0, CamelFileLength=19, JMSTimestamp=1314202952924,
JMSXGroupID=null, JMSDestination=queue://foo,
CamelFileRelativePath=test.txt, JMSType=null, JMSReplyTo=null,
JMSDeliveryMode=2, JMSRedelivered=false,
CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileNameOnly=test.txt, CamelFileName=test.txt}, BodyType:String, Body:7
2011-08-24 18:22:33,015 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:bar]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 17, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:7,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952924, arrival = 0, brokerInTime = 1314202952924, brokerOutTime =
1314202952925, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 7}]
2011-08-24 18:22:33,015 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}
2011-08-24 18:22:33,016 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://bar with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelJmsDeliveryMode=2, CamelFileAbsolute=false}, readOnlyProperties =
false, readOnlyBody = false, droppable = false, text = 7}
2011-08-24 18:22:33,016 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Received message of type [class
org.apache.activemq.command.ActiveMQTextMessage] from consumer
[ActiveMQMessageConsumer {
value=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1:1,
started=true }] of session [PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}]
2011-08-24 18:22:33,016 [msConsumer[foo]] DEBUG
EndpointMessageListener - Endpoint[activemq://queue:foo] consumer
received JMS message: ActiveMQTextMessage {commandId = 19, responseRequired
= true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:9,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952932, arrival = 0, brokerInTime = 1314202952939, brokerOutTime =
1314202952940, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 9}
2011-08-24 18:22:33,017 [msConsumer[foo]] INFO
Tracer -
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:9 >>>
(org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly, Headers:{CamelFileName=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSPriority=4, JMSDestination=queue://foo, CamelFileLastModified=Mon Aug 22
20:03:56 CEST 2011, JMSReplyTo=null, CamelFilePath=src/test/data/test.txt,
JMSTimestamp=1314202952932, CamelFileRelativePath=test.txt,
CamelFileAbsolute=false, CamelFileNameOnly=test.txt,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:9,
CamelFileLength=19, JMSCorrelationID=null, JMSRedelivered=false,
JMSXGroupID=null, CamelFileParent=src/test/data, JMSType=null,
JMSExpiration=0, JMSDeliveryMode=2}, BodyType:String, Body:9
2011-08-24 18:22:33,019 [msConsumer[foo]] DEBUG
SendProcessor - >>>> Endpoint[activemq://queue:bar]
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 19, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:9,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952932, arrival = 0, brokerInTime = 1314202952939, brokerOutTime =
1314202952940, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 9}]
2011-08-24 18:22:33,019 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Executing callback on JMS Session:
PooledSession { ActiveMQSession
{id=ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:1,started=true}
}
2011-08-24 18:22:33,019 [msConsumer[foo]] DEBUG
Configuration$CamelJmsTemplate - Sending JMS message to: queue://bar with
message: ActiveMQTextMessage {commandId = 0, responseRequired = false,
messageId = null, originalDestination = null, originalTransactionId = null,
producerId = null, destination = null, transactionId = null, expiration = 0,
timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, replyTo = null, persistent = true, type = null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0, properties =
{CamelFileNameOnly=test.txt, CamelFileRelativePath=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelJmsDeliveryMode=2, CamelFileAbsolute=false}, readOnlyProperties =
false, readOnlyBody = false, droppable = false, text = 9}
2011-08-24 18:22:33,513 [//src/test/data] DEBUG
FileConsumer - Took 0.001 seconds to poll: src/test/data
2011-08-24 18:22:34,015 [//src/test/data] DEBUG
FileConsumer - Took 0.001 seconds to poll: src/test/data
2011-08-24 18:22:34,517 [//src/test/data] DEBUG
FileConsumer - Took 0.000 seconds to poll: src/test/data
2011-08-24 18:22:35,018 [//src/test/data] DEBUG
FileConsumer - Took 0.001 seconds to poll: src/test/data
2011-08-24 18:22:35,519 [//src/test/data] DEBUG
FileConsumer - Took 0.000 seconds to poll: src/test/data
2011-08-24 18:22:36,021 [//src/test/data] DEBUG
FileConsumer - Took 0.000 seconds to poll: src/test/data
2011-08-24 18:22:36,523 [//src/test/data] DEBUG
FileConsumer - Took 0.001 seconds to poll: src/test/data
2011-08-24 18:22:37,024 [//src/test/data] DEBUG
FileConsumer - Took 0.000 seconds to poll: src/test/data
2011-08-24 18:22:37,526 [//src/test/data] DEBUG
FileConsumer - Took 0.000 seconds to poll: src/test/data
2011-08-24 18:22:38,028 [//src/test/data] DEBUG
FileConsumer - Took 0.001 seconds to poll: src/test/data
2011-08-24 18:22:38,202 [main ] DEBUG
MockEndpoint - Took 10000 millis to complete latch
2011-08-24 18:22:38,202 [main ] DEBUG
MockEndpoint - mock://foo failed and received[1]:
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 10, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:2,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952886, arrival = 0, brokerInTime = 1314202952886, brokerOutTime =
1314202952888, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 2}]
2011-08-24 18:22:38,203 [main ] DEBUG
MockEndpoint - mock://foo failed and received[2]:
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 14, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:4,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952911, arrival = 0, brokerInTime = 1314202952911, brokerOutTime =
1314202952911, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 4}]
2011-08-24 18:22:38,203 [main ] DEBUG
MockEndpoint - mock://foo failed and received[3]:
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 16, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:6,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952917, arrival = 0, brokerInTime = 1314202952917, brokerOutTime =
1314202952918, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 6}]
2011-08-24 18:22:38,204 [main ] DEBUG
MockEndpoint - mock://foo failed and received[4]:
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 18, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:8,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952926, arrival = 0, brokerInTime = 1314202952927, brokerOutTime =
1314202952927, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 8}]
2011-08-24 18:22:38,204 [main ] DEBUG
MockEndpoint - mock://foo failed and received[5]:
Exchange[JmsMessage: ActiveMQTextMessage {commandId = 20, responseRequired =
true, messageId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1:10,
originalDestination = null, originalTransactionId = null, producerId =
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-2:1:3:1,
destination = queue://foo, transactionId = null, expiration = 0, timestamp =
1314202952942, arrival = 0, brokerInTime = 1314202952943, brokerOutTime =
1314202952945, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = false, userID = null, content = null,
marshalledProperties = null, dataStructure = null, redeliveryCounter = 0,
size = 1026, properties = {CamelFileNameOnly=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
breadcrumbId=ID-Christian-Muellers-MacBook-Pro-local-49528-1314202947224-0-2,
CamelFileAbsolute=false}, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text = 0}]
2011-08-24 18:22:38,204 [main ] INFO
Route1Test -
********************************************************************************
2011-08-24 18:22:38,204 [main ] INFO
Route1Test - Testing done:
test(org.apache.cmueller.test.Route1Test)
2011-08-24 18:22:38,205 [main ] INFO
Route1Test - Took: 10.065 seconds (10065 millis)
2011-08-24 18:22:38,205 [main ] INFO
Route1Test -
********************************************************************************
2011-08-24 18:22:38,205 [main ] DEBUG
TestSupport - tearDown test
2011-08-24 18:22:38,205 [main ] INFO
SpringCamelContext - Apache Camel 2.9-SNAPSHOT
(CamelContext:camel) is shutting down
2011-08-24 18:22:38,206 [main ] INFO
DefaultShutdownStrategy - Starting to graceful shutdown 3 routes
(timeout 10 seconds)
2011-08-24 18:22:38,206 [main ] DEBUG
DefaultExecutorServiceManager - Created new ThreadPool for source:
org.apache.camel.impl.DefaultShutdownStrategy@6d3d7254 with name:
ShutdownTask. -> java.util.concurrent.ThreadPoolExecutor@5d1d20d3
2011-08-24 18:22:38,207 [ - ShutdownTask] DEBUG
DefaultShutdownStrategy - There are 3 routes to shutdown
2011-08-24 18:22:38,208 [ - ShutdownTask] DEBUG
DefaultShutdownStrategy - Route: route1 suspended and shutdown
deferred, was consuming from: Endpoint[activemq://queue:foo]
2011-08-24 18:22:38,209 [ - ShutdownTask] DEBUG
DefaultShutdownStrategy - Route: org.apache.cmueller.test.Route2
suspended and shutdown deferred, was consuming from:
Endpoint[activemq://queue:foo]
2011-08-24 18:22:38,209 [ - ShutdownTask] DEBUG
DefaultShutdownStrategy - Route: org.apache.cmueller.test.Route1
suspended and shutdown deferred, was consuming from:
Endpoint[file://src/test/data?initialDelay=5000&noop=true]
2011-08-24 18:22:38,209 [ - ShutdownTask] DEBUG
DefaultShutdownStrategy - Route: org.apache.cmueller.test.Route1
preparing to shutdown complete.
2011-08-24 18:22:38,209 [ - ShutdownTask] DEBUG
JmsMessageListenerContainer - Shutting down JMS listener container
2011-08-24 18:22:38,209 [ - ShutdownTask] DEBUG
JmsMessageListenerContainer - Waiting for shutdown of message listener
invokers
2011-08-24 18:22:38,209 [ - ShutdownTask] DEBUG
JmsMessageListenerContainer - Still waiting for shutdown of 1 message
listener invokers
2011-08-24 18:22:39,016 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Lowered scheduled invoker count: 0
2011-08-24 18:22:39,018 [ - ShutdownTask] DEBUG
JmsConsumer - Stopping consumer:
Consumer[activemq://queue:foo]
2011-08-24 18:22:39,018 [ - ShutdownTask] DEBUG
MockEndpoint$1 - Stopping producer: Producer[mock://foo]
2011-08-24 18:22:39,019 [ - ShutdownTask] INFO
DefaultShutdownStrategy - Route: route1 shutdown complete, was
consuming from: Endpoint[activemq://queue:foo]
2011-08-24 18:22:39,019 [ - ShutdownTask] DEBUG
JmsMessageListenerContainer - Shutting down JMS listener container
2011-08-24 18:22:39,019 [ - ShutdownTask] DEBUG
JmsMessageListenerContainer - Waiting for shutdown of message listener
invokers
2011-08-24 18:22:39,019 [ - ShutdownTask] DEBUG
JmsMessageListenerContainer - Still waiting for shutdown of 1 message
listener invokers
2011-08-24 18:22:39,026 [msConsumer[foo]] DEBUG
JmsMessageListenerContainer - Lowered scheduled invoker count: 0
2011-08-24 18:22:39,026 [ - ShutdownTask] DEBUG
JmsConsumer - Stopping consumer:
Consumer[activemq://queue:foo]
2011-08-24 18:22:39,026 [ - ShutdownTask] DEBUG
JmsProducer - Stopping producer:
Producer[activemq://queue:bar]
2011-08-24 18:22:39,027 [ - ShutdownTask] INFO
DefaultShutdownStrategy - Route: org.apache.cmueller.test.Route2
shutdown complete, was consuming from: Endpoint[activemq://queue:foo]
2011-08-24 18:22:39,027 [ - ShutdownTask] DEBUG
ScheduledPollConsumer - This consumer is stopping, so cancelling
scheduled task:
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@3aeebf17
2011-08-24 18:22:39,027 [ - ShutdownTask] DEBUG
FileConsumer - Stopping consumer:
Consumer[file://src/test/data?initialDelay=5000&noop=true]
2011-08-24 18:22:39,027 [ - ShutdownTask] DEBUG
JmsProducer - Stopping producer:
Producer[activemq://queue:foo]
2011-08-24 18:22:39,027 [ - ShutdownTask] INFO
DefaultShutdownStrategy - Route: org.apache.cmueller.test.Route1
shutdown complete, was consuming from:
Endpoint[file://src/test/data?initialDelay=5000&noop=true]
2011-08-24 18:22:39,027 [main ] INFO
DefaultShutdownStrategy - Graceful shutdown of 3 routes completed in
0 seconds
2011-08-24 18:22:39,028 [main ] DEBUG
RouteService - Stopping services on route: route1
2011-08-24 18:22:39,028 [main ] DEBUG
RouteService - Stopping child service on route: route1 ->
Consumer[activemq://queue:foo]
2011-08-24 18:22:39,028 [main ] DEBUG
RouteService - Stopping child service on route: route1 ->
Instrumentation:route[UnitOfWork(Channel[sendTo(Endpoint[mock://foo])])]
2011-08-24 18:22:39,028 [main ] DEBUG
RouteService - Stopping child service on route: route1 ->
UnitOfWork(Channel[sendTo(Endpoint[mock://foo])])
2011-08-24 18:22:39,028 [main ] DEBUG
RouteService - Stopping child service on route: route1 ->
Channel[sendTo(Endpoint[mock://foo])]
2011-08-24 18:22:39,028 [main ] DEBUG
RouteService - Stopping child service on route: route1 ->
sendTo(Endpoint[mock://foo])
2011-08-24 18:22:39,028 [main ] DEBUG
RouteService - Stopping services on route:
org.apache.cmueller.test.Route2
2011-08-24 18:22:39,028 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route2 -> Consumer[activemq://queue:foo]
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route2 ->
Instrumentation:route[UnitOfWork(Channel[sendTo(Endpoint[activemq://queue:bar])])]
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route2 ->
UnitOfWork(Channel[sendTo(Endpoint[activemq://queue:bar])])
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route2 ->
Channel[sendTo(Endpoint[activemq://queue:bar])]
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route2 -> sendTo(Endpoint[activemq://queue:bar])
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping services on route:
org.apache.cmueller.test.Route1
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route1 ->
Consumer[file://src/test/data?initialDelay=5000&noop=true]
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route1 ->
Instrumentation:route[UnitOfWork(Channel[Splitter[on: tokenize(body, ,) to:
Channel[sendTo(Endpoint[activemq://queue:foo])] aggregate: null]])]
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route1 -> UnitOfWork(Channel[Splitter[on:
tokenize(body, ,) to: Channel[sendTo(Endpoint[activemq://queue:foo])]
aggregate: null]])
2011-08-24 18:22:39,029 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route1 -> Channel[Splitter[on: tokenize(body, ,)
to: Channel[sendTo(Endpoint[activemq://queue:foo])] aggregate: null]]
2011-08-24 18:22:39,030 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route1 -> Splitter[on: tokenize(body, ,) to:
Channel[sendTo(Endpoint[activemq://queue:foo])] aggregate: null]
2011-08-24 18:22:39,030 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route1 ->
Channel[sendTo(Endpoint[activemq://queue:foo])]
2011-08-24 18:22:39,030 [main ] DEBUG
RouteService - Stopping child service on route:
org.apache.cmueller.test.Route1 -> sendTo(Endpoint[activemq://queue:foo])
2011-08-24 18:22:39,030 [main ] DEBUG
DefaultExecutorServiceManager - ShutdownNow ExecutorService:
java.util.concurrent.ThreadPoolExecutor@5d1d20d3
2011-08-24 18:22:39,030 [main ] INFO
DefaultInflightRepository - Shutting down with no inflight exchanges.
2011-08-24 18:22:39,031 [main ] DEBUG
SharedProducerServicePool - Stopping service pool:
org.apache.camel.impl.SharedProducerServicePool@22c28cb7
2011-08-24 18:22:39,031 [main ] DEBUG
DefaultExecutorServiceManager - ShutdownNow ExecutorService:
java.util.concurrent.ScheduledThreadPoolExecutor@4d74f02c
2011-08-24 18:22:39,031 [main ] DEBUG
DefaultExecutorServiceManager - ShutdownNow ExecutorService:
java.util.concurrent.ScheduledThreadPoolExecutor@41a7c484
2011-08-24 18:22:39,031 [main ] DEBUG
DefaultExecutorServiceManager - ShutdownNow ExecutorService:
java.util.concurrent.ThreadPoolExecutor@11b9d4d8
2011-08-24 18:22:39,031 [main ] DEBUG
DefaultExecutorServiceManager - ShutdownNow ExecutorService:
java.util.concurrent.ThreadPoolExecutor@3c992fa5
2011-08-24 18:22:39,031 [main ] INFO
SpringCamelContext - Uptime: 11.538 seconds
2011-08-24 18:22:39,032 [main ] INFO
SpringCamelContext - Apache Camel 2.9-SNAPSHOT (CamelContext:
camel) is shutdown in 0.826 seconds
2011-08-24 18:22:39,032 [main ] INFO
ClassPathXmlApplicationContext - Closing
org.springframework.context.support.ClassPathXmlApplicationContext@5af6ac0b:
startup date [Wed Aug 24 18:22:25 CEST 2011]; parent:
org.springframework.context.support.GenericApplicationContext@571a75a2
2011-08-24 18:22:39,032 [main ] DEBUG
SpringCamelContext - onApplicationEvent:
org.springframework.context.event.ContextClosedEvent[source=org.springframework.context.support.ClassPathXmlApplicationContext@5af6ac0b:
startup date [Wed Aug 24 18:22:25 CEST 2011]; parent:
org.springframework.context.support.GenericApplicationContext@571a75a2]
2011-08-24 18:22:39,033 [main ] INFO
DefaultListableBeanFactory - Destroying singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@49f10a67:
defining beans
[route1,route2,activemq,connectionFactory,template,consumerTemplate,camel:beanPostProcessor,camel];
parent:
org.springframework.beans.factory.support.DefaultListableBeanFactory@31b5998f
2011-08-24 18:22:39,037 [main ] DEBUG
TestSupport - tearDownAfterClass test
2011-08-24 18:22:39,041 [MQ ShutdownHook] INFO
BrokerService - ActiveMQ Message Broker (localhost,
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-0:1) is shutting
down
2011-08-24 18:22:39,042 [MQ ShutdownHook] INFO
TransportConnector - Connector vm://localhost Stopped
2011-08-24 18:22:39,043 [MQ ShutdownHook] INFO
BrokerService - ActiveMQ Message Broker (localhost,
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-0:1) is shutting
down
2011-08-24 18:22:39,050 [MQ ShutdownHook] INFO
BrokerService - ActiveMQ JMS Message Broker (localhost,
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-0:1) stopped
2011-08-24 18:22:39,050 [MQ ShutdownHook] INFO
BrokerService - ActiveMQ JMS Message Broker (localhost,
ID:Christian-Muellers-MacBook-Pro.local-49529-1314202947955-0:1) stopped
Re: Stop a route for unit testing
Posted by Willem Jiang <wi...@gmail.com>.
Hi Christian,
I tried to run the test with Camel 2.8.0 and Camel 2.9-SNAPSHOT.
I don't have the issue that you meet.
On 8/24/11 4:28 AM, Christian Müller wrote:
> Hello Willem!
>
> Thank you for you reply. Unfortunately it doesn't work for me. I updated me
> test to
>
> public class Route1Test extends CamelSpringTestSupport {
>
> @EndpointInject(uri = "mock:foo")
> private MockEndpoint mockEndpointFoo;
>
> @Override
> @Before
> public void setUp() throws Exception {
> super.setUp();
>
> context.removeRoute(Route2.class.getName());
>
> context.addRoutes(new RouteBuilder() {
> @Override
> public void configure() throws Exception {
> from("activemq:queue:foo")
> .to(mockEndpointFoo);
> }
> });
> }
>
> @Test
> public void test() throws Exception {
> mockEndpointFoo.expectedBodiesReceived("1", "2", "3", "4", "5", "6",
> "7", "8", "9", "0");
>
> mockEndpointFoo.assertIsSatisfied();
> }
>
> @Override
> protected AbstractApplicationContext createApplicationContext() {
> return new ClassPathXmlApplicationContext(new String[]
> {"META-INF/spring/bundle-context.xml"},
> getRouteExcludingApplicationContext());
> }
>
> @Override
> protected Class<?> excludeRoute() {
> return Route2.class;
> }
> }
>
> and from the log I can see, the Route2 is still running (attached at the end
> of the file). Do you have another idea how it could work?
>
> I'm thinking to raise a JIRA, because it looks like stopping/removing the
> route doesn't work for this test.
>
> I also hat a look at the chapter 'Test time exclusion' in [1], but it
> doesn't work either for me. I'm running out of ideas... :-(
>
> [1] http://camel.apache.org/spring.html
>
> Best,
> Christian
>
> Aug 23, 2011 10:21:28 PM
> org.springframework.context.support.AbstractApplicationContext
> prepareRefresh
> INFO: Refreshing
> org.springframework.context.support.GenericApplicationContext@f01a1e:
> startup date [Tue Aug 23 22:21:28 CEST 2011]; root of context hierarchy
> Aug 23, 2011 10:21:28 PM
> org.springframework.beans.factory.support.DefaultListableBeanFactory
> preInstantiateSingletons
> INFO: Pre-instantiating singletons in
> org.springframework.beans.factory.support.DefaultListableBeanFactory@60961dff:
> defining beans [excludingResolver]; root of factory hierarchy
> Aug 23, 2011 10:21:28 PM
> org.springframework.context.support.AbstractApplicationContext
> prepareRefresh
> INFO: Refreshing
> org.springframework.context.support.ClassPathXmlApplicationContext@353c375:
> startup date [Tue Aug 23 22:21:28 CEST 2011]; parent:
> org.springframework.context.support.GenericApplicationContext@f01a1e
> Aug 23, 2011 10:21:28 PM
> org.springframework.beans.factory.xml.XmlBeanDefinitionReader
> loadBeanDefinitions
> INFO: Loading XML bean definitions from class path resource
> [META-INF/spring/bundle-context.xml]
> Aug 23, 2011 10:21:28 PM
> org.apache.camel.spring.handler.CamelNamespaceHandler init
> INFO: OSGi environment not detected.
> Aug 23, 2011 10:21:29 PM
> org.springframework.beans.factory.support.DefaultListableBeanFactory
> preInstantiateSingletons
> INFO: Pre-instantiating singletons in
> org.springframework.beans.factory.support.DefaultListableBeanFactory@2b76086d:
> defining beans
> [route1,route2,activemq,connectionFactory,template,consumerTemplate,camel:beanPostProcessor,camel];
> parent:
> org.springframework.beans.factory.support.DefaultListableBeanFactory@60961dff
> Aug 23, 2011 10:21:29 PM
> org.apache.camel.core.xml.AbstractCamelContextFactoryBean afterPropertiesSet
> INFO: Using custom PackageScanClassResolver:
> org.apache.camel.test.junit4.CamelSpringTestSupport$ExcludingPackageScanClassResolver@5e95215b
> Aug 23, 2011 10:21:29 PM
> org.apache.camel.impl.converter.AnnotationTypeConverterLoader load
> INFO: Found 4 packages with 15 @Converter classes to load
> Aug 23, 2011 10:21:29 PM
> org.apache.camel.impl.converter.BaseTypeConverterRegistry loadTypeConverters
> INFO: Loaded 150 type converters in 0.318 seconds
> Aug 23, 2011 10:21:30 PM org.apache.camel.impl.DefaultCamelContext start
> INFO: Apache Camel 2.6.0 (CamelContext: camel) is starting
> Aug 23, 2011 10:21:30 PM org.apache.camel.impl.DefaultCamelContext
> doStartCamel
> INFO: Tracing is enabled on CamelContext: camel
> Aug 23, 2011 10:21:30 PM org.apache.camel.impl.DefaultCamelContext
> createManagementStrategy
> INFO: JMX enabled. Using ManagedManagementStrategy.
> Aug 23, 2011 10:21:30 PM org.apache.camel.component.file.FileEndpoint
> createConsumer
> INFO: Endpoint is configured with noop=true so forcing endpoint to be
> idempotent as well
> Aug 23, 2011 10:21:30 PM org.apache.camel.component.file.FileEndpoint
> createConsumer
> INFO: Using default memory based idempotent repository with cache max size:
> 1000
> Aug 23, 2011 10:21:30 PM org.apache.camel.impl.DefaultCamelContext
> doStartOrResumeRouteConsumers
> INFO: Route: org.apache.cmueller.test.Route1 started and consuming from:
> Endpoint[file://src/test/data?initialDelay=5000&noop=true]
> Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.BrokerService start
> INFO: Using Persistence Adapter: MemoryPersistenceAdapter
> Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.BrokerService getBroker
> INFO: ActiveMQ 5.4.2 JMS Message Broker (localhost) is starting
> Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.BrokerService getBroker
> INFO: For help or more information please see: http://activemq.apache.org/
> Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.BrokerService start
> INFO: ActiveMQ JMS Message Broker (localhost,
> ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-0:1) started
> Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.TransportConnector start
> INFO: Connector vm://localhost Started
> Aug 23, 2011 10:21:31 PM org.apache.camel.impl.DefaultCamelContext
> doStartOrResumeRouteConsumers
> INFO: Route: org.apache.cmueller.test.Route2 started and consuming from:
> Endpoint[activemq://queue:foo]
> Aug 23, 2011 10:21:31 PM org.apache.camel.impl.DefaultCamelContext start
> INFO: Total 2 routes, of which 2 is started.
> Aug 23, 2011 10:21:31 PM org.apache.camel.impl.DefaultCamelContext start
> INFO: Apache Camel 2.6.0 (CamelContext: camel) started in 0.995 seconds
> Aug 23, 2011 10:21:31 PM org.apache.camel.test.junit4.CamelTestSupport setUp
> INFO:
> ********************************************************************************
> Aug 23, 2011 10:21:31 PM org.apache.camel.test.junit4.CamelTestSupport setUp
> INFO: Testing: (org.apache.cmueller.test.Route1Test)
> Aug 23, 2011 10:21:31 PM org.apache.camel.test.junit4.CamelTestSupport setUp
> INFO:
> ********************************************************************************
> Aug 23, 2011 10:21:31 PM org.apache.camel.impl.DefaultCamelContext
> doStartOrResumeRouteConsumers
> INFO: Route: route1 started and consuming from:
> Endpoint[activemq://queue:foo]
> Aug 23, 2011 10:21:31 PM org.apache.camel.component.mock.MockEndpoint
> assertIsSatisfied
> INFO: Asserting: Endpoint[mock://foo] is satisfied
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-2>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> split[tokenize(body, ,)]<<< Pattern:InOnly,
> Headers:{CamelFileAbsolute=false, CamelFilePath=src/test/data/test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileRelativePath=test.txt, CamelFileParent=src/test/data,
> CamelFileLength=19, CamelFileName=test.txt, CamelFileNameOnly=test.txt,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011},
> BodyType:org.apache.camel.component.file.GenericFile,
> Body:1,2,3,4,5,6,7,8,9,0
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-3>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly,
> Headers:{CamelFilePath=src/test/data/test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileParent=src/test/data, CamelFileRelativePath=test.txt,
> CamelFileName=test.txt, CamelFileNameOnly=test.txt,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileAbsolute=false, CamelFileLength=19}, BodyType:String, Body:1
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-4>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly,
> Headers:{CamelFileRelativePath=test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileNameOnly=test.txt, CamelFileParent=src/test/data,
> CamelFilePath=src/test/data/test.txt, CamelFileLength=19,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileAbsolute=false, CamelFileName=test.txt}, BodyType:String, Body:2
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-5>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly, Headers:{CamelFileName=test.txt,
> CamelFileNameOnly=test.txt, CamelFileLength=19,
> CamelFilePath=src/test/data/test.txt, CamelFileAbsolute=false,
> CamelFileParent=src/test/data,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileRelativePath=test.txt}, BodyType:String, Body:3
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-6>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly,
> Headers:{CamelFilePath=src/test/data/test.txt, CamelFileName=test.txt,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, CamelFileLength=19,
> CamelFileAbsolute=false, CamelFileParent=src/test/data,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt},
> BodyType:String, Body:4
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-7>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly,
> Headers:{CamelFilePath=src/test/data/test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileAbsolute=false, CamelFileParent=src/test/data,
> CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt,
> CamelFileName=test.txt, CamelFileLength=19}, BodyType:String, Body:5
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-8>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly,
> Headers:{CamelFilePath=src/test/data/test.txt, CamelFileLastModified=Mon Aug
> 22 20:03:56 CEST 2011, CamelFileNameOnly=test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileRelativePath=test.txt, CamelFileName=test.txt,
> CamelFileAbsolute=false, CamelFileParent=src/test/data, CamelFileLength=19},
> BodyType:String, Body:6
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-9>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly,
> Headers:{CamelFileRelativePath=test.txt, CamelFileAbsolute=false,
> CamelFileName=test.txt, CamelFileNameOnly=test.txt,
> CamelFilePath=src/test/data/test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileLength=19, CamelFileParent=src/test/data, CamelFileLastModified=Mon
> Aug 22 20:03:56 CEST 2011}, BodyType:String, Body:7
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-10>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly,
> Headers:{CamelFileNameOnly=test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileRelativePath=test.txt, CamelFileLength=19,
> CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileAbsolute=false, CamelFileName=test.txt}, BodyType:String, Body:8
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:1
>>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
> activemq://queue:bar<<< Pattern:InOnly, Headers:{JMSCorrelationID=null,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, JMSXGroupID=null,
> CamelFileLength=19, CamelFileRelativePath=test.txt,
> CamelFileNameOnly=test.txt, JMSDestination=queue://foo,
> JMSRedelivered=false,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:1,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileName=test.txt, JMSExpiration=0, JMSDeliveryMode=2,
> CamelFileParent=src/test/data, JMSType=null, JMSTimestamp=1314130895824,
> JMSPriority=4, CamelFilePath=src/test/data/test.txt, JMSReplyTo=null,
> CamelFileAbsolute=false}, BodyType:String, Body:1
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:2
>>>> (route1) from(activemq://queue:foo) --> mock://foo<<< Pattern:InOnly,
> Headers:{CamelFileAbsolute=false, CamelFileName=test.txt, JMSReplyTo=null,
> CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt,
> JMSCorrelationID=null, JMSDestination=queue://foo, JMSXGroupID=null,
> JMSPriority=4, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileLength=19, JMSExpiration=0,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFilePath=src/test/data/test.txt, JMSRedelivered=false,
> JMSDeliveryMode=2, JMSType=null, CamelFileParent=src/test/data,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:2,
> JMSTimestamp=1314130895858}, BodyType:String, Body:2
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:4
>>>> (route1) from(activemq://queue:foo) --> mock://foo<<< Pattern:InOnly,
> Headers:{CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> JMSCorrelationID=null, JMSExpiration=0, JMSReplyTo=null, JMSDeliveryMode=2,
> JMSRedelivered=false, CamelFileName=test.txt, CamelFileAbsolute=false,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:4,
> JMSDestination=queue://foo, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
> 2011, CamelFileNameOnly=test.txt, CamelFileParent=src/test/data,
> JMSXGroupID=null, JMSTimestamp=1314130895871, CamelFileLength=19,
> CamelFilePath=src/test/data/test.txt, JMSPriority=4, JMSType=null,
> CamelFileRelativePath=test.txt}, BodyType:String, Body:4
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:6
>>>> (route1) from(activemq://queue:foo) --> mock://foo<<< Pattern:InOnly,
> Headers:{CamelFileRelativePath=test.txt, JMSTimestamp=1314130895875,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileLength=19, JMSDestination=queue://foo, JMSDeliveryMode=2,
> JMSXGroupID=null, JMSType=null, JMSCorrelationID=null, JMSPriority=4,
> JMSExpiration=0, JMSReplyTo=null, CamelFileName=test.txt,
> JMSRedelivered=false, CamelFileAbsolute=false, CamelFileLastModified=Mon Aug
> 22 20:03:56 CEST 2011, CamelFilePath=src/test/data/test.txt,
> CamelFileNameOnly=test.txt,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:6,
> CamelFileParent=src/test/data}, BodyType:String, Body:6
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:8
>>>> (route1) from(activemq://queue:foo) --> mock://foo<<< Pattern:InOnly,
> Headers:{CamelFileName=test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> JMSDestination=queue://foo, JMSCorrelationID=null, JMSReplyTo=null,
> CamelFileRelativePath=test.txt, JMSPriority=4, CamelFileLength=19,
> JMSTimestamp=1314130895930, CamelFileNameOnly=test.txt,
> JMSRedelivered=false,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:8,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, JMSDeliveryMode=2,
> CamelFileAbsolute=false, JMSXGroupID=null, JMSType=null,
> CamelFilePath=src/test/data/test.txt, JMSExpiration=0,
> CamelFileParent=src/test/data}, BodyType:String, Body:8
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-11>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly,
> Headers:{CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
> CamelFileRelativePath=test.txt, CamelFileLength=19, CamelFileName=test.txt,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileNameOnly=test.txt, CamelFileAbsolute=false}, BodyType:String,
> Body:9
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:3
>>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
> activemq://queue:bar<<< Pattern:InOnly,
> Headers:{JMSTimestamp=1314130895869, CamelFileAbsolute=false,
> CamelFileNameOnly=test.txt, CamelFileParent=src/test/data, JMSReplyTo=null,
> JMSPriority=4, CamelFileRelativePath=test.txt, JMSXGroupID=null,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileName=test.txt, JMSExpiration=0, JMSRedelivered=false,
> JMSDeliveryMode=2, CamelFilePath=src/test/data/test.txt, CamelFileLength=19,
> JMSType=null, JMSCorrelationID=null,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:3,
> JMSDestination=queue://foo}, BodyType:String, Body:3
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-12>>>
> (org.apache.cmueller.test.Route1)
> from(file://src/test/data?initialDelay=5000&noop=true) -->
> activemq://queue:foo<<< Pattern:InOnly, Headers:{CamelFileName=test.txt,
> CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
> CEST 2011, CamelFileAbsolute=false, CamelFileParent=src/test/data,
> CamelFilePath=src/test/data/test.txt, CamelFileLength=19,
> CamelFileNameOnly=test.txt,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt},
> BodyType:String, Body:0
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:10
>>>> (route1) from(activemq://queue:foo) --> mock://foo<<< Pattern:InOnly,
> Headers:{JMSDeliveryMode=2, JMSRedelivered=false,
> CamelFilePath=src/test/data/test.txt, JMSCorrelationID=null,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, CamelFileLength=19,
> CamelFileNameOnly=test.txt, CamelFileParent=src/test/data, JMSType=null,
> JMSTimestamp=1314130895948, JMSXGroupID=null, JMSReplyTo=null,
> CamelFileAbsolute=false, JMSExpiration=0, CamelFileName=test.txt,
> JMSDestination=queue://foo,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> CamelFileRelativePath=test.txt, JMSPriority=4,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:10},
> BodyType:String, Body:0
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:5
>>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
> activemq://queue:bar<<< Pattern:InOnly,
> Headers:{CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> JMSDeliveryMode=2, CamelFileParent=src/test/data, JMSXGroupID=null,
> JMSCorrelationID=null, JMSReplyTo=null, CamelFileName=test.txt,
> CamelFileAbsolute=false, JMSRedelivered=false, CamelFileNameOnly=test.txt,
> CamelFilePath=src/test/data/test.txt, JMSPriority=4, CamelFileLength=19,
> JMSType=null, JMSExpiration=0, CamelFileRelativePath=test.txt,
> JMSDestination=queue://foo, JMSTimestamp=1314130895873,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:5,
> CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011}, BodyType:String,
> Body:5
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:7
>>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
> activemq://queue:bar<<< Pattern:InOnly, Headers:{JMSDeliveryMode=2,
> JMSPriority=4, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileRelativePath=test.txt, JMSXGroupID=null,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:7,
> JMSRedelivered=false, JMSTimestamp=1314130895878, CamelFileLength=19,
> JMSExpiration=0, CamelFileAbsolute=false,
> CamelFilePath=src/test/data/test.txt, JMSCorrelationID=null,
> CamelFileParent=src/test/data, JMSReplyTo=null, JMSDestination=queue://foo,
> CamelFileNameOnly=test.txt, JMSType=null, CamelFileName=test.txt},
> BodyType:String, Body:7
> Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
> INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:9
>>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
> activemq://queue:bar<<< Pattern:InOnly,
> Headers:{JMSDestination=queue://foo,
> JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:9,
> JMSType=null, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
> CamelFileRelativePath=test.txt, CamelFileName=test.txt,
> CamelFilePath=src/test/data/test.txt, JMSExpiration=0, JMSXGroupID=null,
> JMSTimestamp=1314130895942, JMSDeliveryMode=2, JMSPriority=4,
> CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
> JMSReplyTo=null, JMSCorrelationID=null, CamelFileNameOnly=test.txt,
> JMSRedelivered=false, CamelFileParent=src/test/data,
> CamelFileAbsolute=false, CamelFileLength=19}, BodyType:String, Body:9
> Aug 23, 2011 10:21:41 PM org.apache.camel.test.junit4.CamelTestSupport
> tearDown
> INFO: Testing done: org.apache.cmueller.test.Route1Test@72b398da
> Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultCamelContext doStop
> INFO: Apache Camel 2.6.0 (CamelContext:camel) is shutting down
> Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultShutdownStrategy
> doShutdown
> INFO: Starting to graceful shutdown 3 routes (timeout 10 seconds)
> Aug 23, 2011 10:21:41 PM
> org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
> INFO: Route: route1 suspended and shutdown deferred, was consuming from:
> Endpoint[activemq://queue:foo]
> Aug 23, 2011 10:21:41 PM
> org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
> INFO: Route: org.apache.cmueller.test.Route2 suspended and shutdown
> deferred, was consuming from: Endpoint[activemq://queue:foo]
> Aug 23, 2011 10:21:41 PM
> org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
> INFO: Route: org.apache.cmueller.test.Route1 suspended and shutdown
> deferred, was consuming from:
> Endpoint[file://src/test/data?initialDelay=5000&noop=true]
> Aug 23, 2011 10:21:41 PM
> org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
> INFO: Route: org.apache.cmueller.test.Route1 preparing to shutdown complete.
> Aug 23, 2011 10:21:41 PM
> org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
> INFO: Route: route1 shutdown complete.
> Aug 23, 2011 10:21:41 PM
> org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
> INFO: Route: org.apache.cmueller.test.Route2 shutdown complete.
> Aug 23, 2011 10:21:41 PM
> org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
> INFO: Route: org.apache.cmueller.test.Route1 shutdown complete.
> Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultShutdownStrategy
> doShutdown
> INFO: Graceful shutdown of 3 routes completed in 0 seconds
> Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultInflightRepository
> doStop
> INFO: Shutting down with no inflight exchanges.
> Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultCamelContext doStop
> INFO: Uptime: 11.924 seconds
> Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultCamelContext doStop
> INFO: Apache Camel 2.6.0 (CamelContext: camel) is shutdown in 0.805 seconds
> Aug 23, 2011 10:21:41 PM
> org.springframework.context.support.AbstractApplicationContext doClose
> INFO: Closing
> org.springframework.context.support.ClassPathXmlApplicationContext@353c375:
> startup date [Tue Aug 23 22:21:28 CEST 2011]; parent:
> org.springframework.context.support.GenericApplicationContext@f01a1e
> Aug 23, 2011 10:21:41 PM
> org.springframework.beans.factory.support.DefaultSingletonBeanRegistry
> destroySingletons
> INFO: Destroying singletons in
> org.springframework.beans.factory.support.DefaultListableBeanFactory@2b76086d:
> defining beans
> [route1,route2,activemq,connectionFactory,template,consumerTemplate,camel:beanPostProcessor,camel];
> parent:
> org.springframework.beans.factory.support.DefaultListableBeanFactory@60961dff
> Aug 23, 2011 10:21:41 PM org.apache.activemq.broker.BrokerService stop
> INFO: ActiveMQ Message Broker (localhost,
> ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-0:1) is shutting
> down
>
--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang
Re: Stop a route for unit testing
Posted by Christian Müller <ch...@gmail.com>.
Hello Willem!
Thank you for you reply. Unfortunately it doesn't work for me. I updated me
test to
public class Route1Test extends CamelSpringTestSupport {
@EndpointInject(uri = "mock:foo")
private MockEndpoint mockEndpointFoo;
@Override
@Before
public void setUp() throws Exception {
super.setUp();
context.removeRoute(Route2.class.getName());
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("activemq:queue:foo")
.to(mockEndpointFoo);
}
});
}
@Test
public void test() throws Exception {
mockEndpointFoo.expectedBodiesReceived("1", "2", "3", "4", "5", "6",
"7", "8", "9", "0");
mockEndpointFoo.assertIsSatisfied();
}
@Override
protected AbstractApplicationContext createApplicationContext() {
return new ClassPathXmlApplicationContext(new String[]
{"META-INF/spring/bundle-context.xml"},
getRouteExcludingApplicationContext());
}
@Override
protected Class<?> excludeRoute() {
return Route2.class;
}
}
and from the log I can see, the Route2 is still running (attached at the end
of the file). Do you have another idea how it could work?
I'm thinking to raise a JIRA, because it looks like stopping/removing the
route doesn't work for this test.
I also hat a look at the chapter 'Test time exclusion' in [1], but it
doesn't work either for me. I'm running out of ideas... :-(
[1] http://camel.apache.org/spring.html
Best,
Christian
Aug 23, 2011 10:21:28 PM
org.springframework.context.support.AbstractApplicationContext
prepareRefresh
INFO: Refreshing
org.springframework.context.support.GenericApplicationContext@f01a1e:
startup date [Tue Aug 23 22:21:28 CEST 2011]; root of context hierarchy
Aug 23, 2011 10:21:28 PM
org.springframework.beans.factory.support.DefaultListableBeanFactory
preInstantiateSingletons
INFO: Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@60961dff:
defining beans [excludingResolver]; root of factory hierarchy
Aug 23, 2011 10:21:28 PM
org.springframework.context.support.AbstractApplicationContext
prepareRefresh
INFO: Refreshing
org.springframework.context.support.ClassPathXmlApplicationContext@353c375:
startup date [Tue Aug 23 22:21:28 CEST 2011]; parent:
org.springframework.context.support.GenericApplicationContext@f01a1e
Aug 23, 2011 10:21:28 PM
org.springframework.beans.factory.xml.XmlBeanDefinitionReader
loadBeanDefinitions
INFO: Loading XML bean definitions from class path resource
[META-INF/spring/bundle-context.xml]
Aug 23, 2011 10:21:28 PM
org.apache.camel.spring.handler.CamelNamespaceHandler init
INFO: OSGi environment not detected.
Aug 23, 2011 10:21:29 PM
org.springframework.beans.factory.support.DefaultListableBeanFactory
preInstantiateSingletons
INFO: Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@2b76086d:
defining beans
[route1,route2,activemq,connectionFactory,template,consumerTemplate,camel:beanPostProcessor,camel];
parent:
org.springframework.beans.factory.support.DefaultListableBeanFactory@60961dff
Aug 23, 2011 10:21:29 PM
org.apache.camel.core.xml.AbstractCamelContextFactoryBean afterPropertiesSet
INFO: Using custom PackageScanClassResolver:
org.apache.camel.test.junit4.CamelSpringTestSupport$ExcludingPackageScanClassResolver@5e95215b
Aug 23, 2011 10:21:29 PM
org.apache.camel.impl.converter.AnnotationTypeConverterLoader load
INFO: Found 4 packages with 15 @Converter classes to load
Aug 23, 2011 10:21:29 PM
org.apache.camel.impl.converter.BaseTypeConverterRegistry loadTypeConverters
INFO: Loaded 150 type converters in 0.318 seconds
Aug 23, 2011 10:21:30 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Apache Camel 2.6.0 (CamelContext: camel) is starting
Aug 23, 2011 10:21:30 PM org.apache.camel.impl.DefaultCamelContext
doStartCamel
INFO: Tracing is enabled on CamelContext: camel
Aug 23, 2011 10:21:30 PM org.apache.camel.impl.DefaultCamelContext
createManagementStrategy
INFO: JMX enabled. Using ManagedManagementStrategy.
Aug 23, 2011 10:21:30 PM org.apache.camel.component.file.FileEndpoint
createConsumer
INFO: Endpoint is configured with noop=true so forcing endpoint to be
idempotent as well
Aug 23, 2011 10:21:30 PM org.apache.camel.component.file.FileEndpoint
createConsumer
INFO: Using default memory based idempotent repository with cache max size:
1000
Aug 23, 2011 10:21:30 PM org.apache.camel.impl.DefaultCamelContext
doStartOrResumeRouteConsumers
INFO: Route: org.apache.cmueller.test.Route1 started and consuming from:
Endpoint[file://src/test/data?initialDelay=5000&noop=true]
Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.BrokerService start
INFO: Using Persistence Adapter: MemoryPersistenceAdapter
Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.BrokerService getBroker
INFO: ActiveMQ 5.4.2 JMS Message Broker (localhost) is starting
Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.BrokerService getBroker
INFO: For help or more information please see: http://activemq.apache.org/
Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.BrokerService start
INFO: ActiveMQ JMS Message Broker (localhost,
ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-0:1) started
Aug 23, 2011 10:21:30 PM org.apache.activemq.broker.TransportConnector start
INFO: Connector vm://localhost Started
Aug 23, 2011 10:21:31 PM org.apache.camel.impl.DefaultCamelContext
doStartOrResumeRouteConsumers
INFO: Route: org.apache.cmueller.test.Route2 started and consuming from:
Endpoint[activemq://queue:foo]
Aug 23, 2011 10:21:31 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Total 2 routes, of which 2 is started.
Aug 23, 2011 10:21:31 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Apache Camel 2.6.0 (CamelContext: camel) started in 0.995 seconds
Aug 23, 2011 10:21:31 PM org.apache.camel.test.junit4.CamelTestSupport setUp
INFO:
********************************************************************************
Aug 23, 2011 10:21:31 PM org.apache.camel.test.junit4.CamelTestSupport setUp
INFO: Testing: (org.apache.cmueller.test.Route1Test)
Aug 23, 2011 10:21:31 PM org.apache.camel.test.junit4.CamelTestSupport setUp
INFO:
********************************************************************************
Aug 23, 2011 10:21:31 PM org.apache.camel.impl.DefaultCamelContext
doStartOrResumeRouteConsumers
INFO: Route: route1 started and consuming from:
Endpoint[activemq://queue:foo]
Aug 23, 2011 10:21:31 PM org.apache.camel.component.mock.MockEndpoint
assertIsSatisfied
INFO: Asserting: Endpoint[mock://foo] is satisfied
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-2 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
split[tokenize(body, ,)] <<< Pattern:InOnly,
Headers:{CamelFileAbsolute=false, CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileRelativePath=test.txt, CamelFileParent=src/test/data,
CamelFileLength=19, CamelFileName=test.txt, CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011},
BodyType:org.apache.camel.component.file.GenericFile,
Body:1,2,3,4,5,6,7,8,9,0
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-3 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileParent=src/test/data, CamelFileRelativePath=test.txt,
CamelFileName=test.txt, CamelFileNameOnly=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolute=false, CamelFileLength=19}, BodyType:String, Body:1
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-4 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileRelativePath=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileNameOnly=test.txt, CamelFileParent=src/test/data,
CamelFilePath=src/test/data/test.txt, CamelFileLength=19,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolute=false, CamelFileName=test.txt}, BodyType:String, Body:2
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-5 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly, Headers:{CamelFileName=test.txt,
CamelFileNameOnly=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileAbsolute=false,
CamelFileParent=src/test/data,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt}, BodyType:String, Body:3
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-6 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFilePath=src/test/data/test.txt, CamelFileName=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, CamelFileLength=19,
CamelFileAbsolute=false, CamelFileParent=src/test/data,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt},
BodyType:String, Body:4
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-7 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolute=false, CamelFileParent=src/test/data,
CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt,
CamelFileName=test.txt, CamelFileLength=19}, BodyType:String, Body:5
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-8 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFilePath=src/test/data/test.txt, CamelFileLastModified=Mon Aug
22 20:03:56 CEST 2011, CamelFileNameOnly=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileRelativePath=test.txt, CamelFileName=test.txt,
CamelFileAbsolute=false, CamelFileParent=src/test/data, CamelFileLength=19},
BodyType:String, Body:6
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-9 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileRelativePath=test.txt, CamelFileAbsolute=false,
CamelFileName=test.txt, CamelFileNameOnly=test.txt,
CamelFilePath=src/test/data/test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, CamelFileParent=src/test/data, CamelFileLastModified=Mon
Aug 22 20:03:56 CEST 2011}, BodyType:String, Body:7
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-10 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileNameOnly=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileRelativePath=test.txt, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolute=false, CamelFileName=test.txt}, BodyType:String, Body:8
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:1
>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly, Headers:{JMSCorrelationID=null,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, JMSXGroupID=null,
CamelFileLength=19, CamelFileRelativePath=test.txt,
CamelFileNameOnly=test.txt, JMSDestination=queue://foo,
JMSRedelivered=false,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:1,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, JMSExpiration=0, JMSDeliveryMode=2,
CamelFileParent=src/test/data, JMSType=null, JMSTimestamp=1314130895824,
JMSPriority=4, CamelFilePath=src/test/data/test.txt, JMSReplyTo=null,
CamelFileAbsolute=false}, BodyType:String, Body:1
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:2
>>> (route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{CamelFileAbsolute=false, CamelFileName=test.txt, JMSReplyTo=null,
CamelFileRelativePath=test.txt, CamelFileNameOnly=test.txt,
JMSCorrelationID=null, JMSDestination=queue://foo, JMSXGroupID=null,
JMSPriority=4, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileLength=19, JMSExpiration=0,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFilePath=src/test/data/test.txt, JMSRedelivered=false,
JMSDeliveryMode=2, JMSType=null, CamelFileParent=src/test/data,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:2,
JMSTimestamp=1314130895858}, BodyType:String, Body:2
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:4
>>> (route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSCorrelationID=null, JMSExpiration=0, JMSReplyTo=null, JMSDeliveryMode=2,
JMSRedelivered=false, CamelFileName=test.txt, CamelFileAbsolute=false,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:4,
JMSDestination=queue://foo, CamelFileLastModified=Mon Aug 22 20:03:56 CEST
2011, CamelFileNameOnly=test.txt, CamelFileParent=src/test/data,
JMSXGroupID=null, JMSTimestamp=1314130895871, CamelFileLength=19,
CamelFilePath=src/test/data/test.txt, JMSPriority=4, JMSType=null,
CamelFileRelativePath=test.txt}, BodyType:String, Body:4
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:6
>>> (route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{CamelFileRelativePath=test.txt, JMSTimestamp=1314130895875,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileLength=19, JMSDestination=queue://foo, JMSDeliveryMode=2,
JMSXGroupID=null, JMSType=null, JMSCorrelationID=null, JMSPriority=4,
JMSExpiration=0, JMSReplyTo=null, CamelFileName=test.txt,
JMSRedelivered=false, CamelFileAbsolute=false, CamelFileLastModified=Mon Aug
22 20:03:56 CEST 2011, CamelFilePath=src/test/data/test.txt,
CamelFileNameOnly=test.txt,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:6,
CamelFileParent=src/test/data}, BodyType:String, Body:6
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:8
>>> (route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{CamelFileName=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSDestination=queue://foo, JMSCorrelationID=null, JMSReplyTo=null,
CamelFileRelativePath=test.txt, JMSPriority=4, CamelFileLength=19,
JMSTimestamp=1314130895930, CamelFileNameOnly=test.txt,
JMSRedelivered=false,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:8,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, JMSDeliveryMode=2,
CamelFileAbsolute=false, JMSXGroupID=null, JMSType=null,
CamelFilePath=src/test/data/test.txt, JMSExpiration=0,
CamelFileParent=src/test/data}, BodyType:String, Body:8
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-11 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly,
Headers:{CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFilePath=src/test/data/test.txt, CamelFileParent=src/test/data,
CamelFileRelativePath=test.txt, CamelFileLength=19, CamelFileName=test.txt,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileNameOnly=test.txt, CamelFileAbsolute=false}, BodyType:String,
Body:9
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:3
>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly,
Headers:{JMSTimestamp=1314130895869, CamelFileAbsolute=false,
CamelFileNameOnly=test.txt, CamelFileParent=src/test/data, JMSReplyTo=null,
JMSPriority=4, CamelFileRelativePath=test.txt, JMSXGroupID=null,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileName=test.txt, JMSExpiration=0, JMSRedelivered=false,
JMSDeliveryMode=2, CamelFilePath=src/test/data/test.txt, CamelFileLength=19,
JMSType=null, JMSCorrelationID=null,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:3,
JMSDestination=queue://foo}, BodyType:String, Body:3
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID-Christian-Muellers-MacBook-Pro-local-49747-1314130889501-0-12 >>>
(org.apache.cmueller.test.Route1)
from(file://src/test/data?initialDelay=5000&noop=true) -->
activemq://queue:foo <<< Pattern:InOnly, Headers:{CamelFileName=test.txt,
CamelFileRelativePath=test.txt, CamelFileLastModified=Mon Aug 22 20:03:56
CEST 2011, CamelFileAbsolute=false, CamelFileParent=src/test/data,
CamelFilePath=src/test/data/test.txt, CamelFileLength=19,
CamelFileNameOnly=test.txt,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt},
BodyType:String, Body:0
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:10
>>> (route1) from(activemq://queue:foo) --> mock://foo <<< Pattern:InOnly,
Headers:{JMSDeliveryMode=2, JMSRedelivered=false,
CamelFilePath=src/test/data/test.txt, JMSCorrelationID=null,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011, CamelFileLength=19,
CamelFileNameOnly=test.txt, CamelFileParent=src/test/data, JMSType=null,
JMSTimestamp=1314130895948, JMSXGroupID=null, JMSReplyTo=null,
CamelFileAbsolute=false, JMSExpiration=0, CamelFileName=test.txt,
JMSDestination=queue://foo,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
CamelFileRelativePath=test.txt, JMSPriority=4,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:10},
BodyType:String, Body:0
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:5
>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly,
Headers:{CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSDeliveryMode=2, CamelFileParent=src/test/data, JMSXGroupID=null,
JMSCorrelationID=null, JMSReplyTo=null, CamelFileName=test.txt,
CamelFileAbsolute=false, JMSRedelivered=false, CamelFileNameOnly=test.txt,
CamelFilePath=src/test/data/test.txt, JMSPriority=4, CamelFileLength=19,
JMSType=null, JMSExpiration=0, CamelFileRelativePath=test.txt,
JMSDestination=queue://foo, JMSTimestamp=1314130895873,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:5,
CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011}, BodyType:String,
Body:5
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:7
>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly, Headers:{JMSDeliveryMode=2,
JMSPriority=4, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt, JMSXGroupID=null,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:7,
JMSRedelivered=false, JMSTimestamp=1314130895878, CamelFileLength=19,
JMSExpiration=0, CamelFileAbsolute=false,
CamelFilePath=src/test/data/test.txt, JMSCorrelationID=null,
CamelFileParent=src/test/data, JMSReplyTo=null, JMSDestination=queue://foo,
CamelFileNameOnly=test.txt, JMSType=null, CamelFileName=test.txt},
BodyType:String, Body:7
Aug 23, 2011 10:21:35 PM org.apache.camel.processor.Logger process
INFO: ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:9
>>> (org.apache.cmueller.test.Route2) from(activemq://queue:foo) -->
activemq://queue:bar <<< Pattern:InOnly,
Headers:{JMSDestination=queue://foo,
JMSMessageID=ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-2:1:3:1:9,
JMSType=null, CamelFileLastModified=Mon Aug 22 20:03:56 CEST 2011,
CamelFileRelativePath=test.txt, CamelFileName=test.txt,
CamelFilePath=src/test/data/test.txt, JMSExpiration=0, JMSXGroupID=null,
JMSTimestamp=1314130895942, JMSDeliveryMode=2, JMSPriority=4,
CamelFileAbsolutePath=/Users/cmueller/workspaceApacheGitSVN/camel-context-start-test/src/test/data/test.txt,
JMSReplyTo=null, JMSCorrelationID=null, CamelFileNameOnly=test.txt,
JMSRedelivered=false, CamelFileParent=src/test/data,
CamelFileAbsolute=false, CamelFileLength=19}, BodyType:String, Body:9
Aug 23, 2011 10:21:41 PM org.apache.camel.test.junit4.CamelTestSupport
tearDown
INFO: Testing done: org.apache.cmueller.test.Route1Test@72b398da
Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultCamelContext doStop
INFO: Apache Camel 2.6.0 (CamelContext:camel) is shutting down
Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultShutdownStrategy
doShutdown
INFO: Starting to graceful shutdown 3 routes (timeout 10 seconds)
Aug 23, 2011 10:21:41 PM
org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
INFO: Route: route1 suspended and shutdown deferred, was consuming from:
Endpoint[activemq://queue:foo]
Aug 23, 2011 10:21:41 PM
org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
INFO: Route: org.apache.cmueller.test.Route2 suspended and shutdown
deferred, was consuming from: Endpoint[activemq://queue:foo]
Aug 23, 2011 10:21:41 PM
org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
INFO: Route: org.apache.cmueller.test.Route1 suspended and shutdown
deferred, was consuming from:
Endpoint[file://src/test/data?initialDelay=5000&noop=true]
Aug 23, 2011 10:21:41 PM
org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
INFO: Route: org.apache.cmueller.test.Route1 preparing to shutdown complete.
Aug 23, 2011 10:21:41 PM
org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
INFO: Route: route1 shutdown complete.
Aug 23, 2011 10:21:41 PM
org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
INFO: Route: org.apache.cmueller.test.Route2 shutdown complete.
Aug 23, 2011 10:21:41 PM
org.apache.camel.impl.DefaultShutdownStrategy$ShutdownTask run
INFO: Route: org.apache.cmueller.test.Route1 shutdown complete.
Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultShutdownStrategy
doShutdown
INFO: Graceful shutdown of 3 routes completed in 0 seconds
Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultInflightRepository
doStop
INFO: Shutting down with no inflight exchanges.
Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultCamelContext doStop
INFO: Uptime: 11.924 seconds
Aug 23, 2011 10:21:41 PM org.apache.camel.impl.DefaultCamelContext doStop
INFO: Apache Camel 2.6.0 (CamelContext: camel) is shutdown in 0.805 seconds
Aug 23, 2011 10:21:41 PM
org.springframework.context.support.AbstractApplicationContext doClose
INFO: Closing
org.springframework.context.support.ClassPathXmlApplicationContext@353c375:
startup date [Tue Aug 23 22:21:28 CEST 2011]; parent:
org.springframework.context.support.GenericApplicationContext@f01a1e
Aug 23, 2011 10:21:41 PM
org.springframework.beans.factory.support.DefaultSingletonBeanRegistry
destroySingletons
INFO: Destroying singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@2b76086d:
defining beans
[route1,route2,activemq,connectionFactory,template,consumerTemplate,camel:beanPostProcessor,camel];
parent:
org.springframework.beans.factory.support.DefaultListableBeanFactory@60961dff
Aug 23, 2011 10:21:41 PM org.apache.activemq.broker.BrokerService stop
INFO: ActiveMQ Message Broker (localhost,
ID:Christian-Muellers-MacBook-Pro.local-49748-1314130890845-0:1) is shutting
down
Re: Stop a route for unit testing
Posted by Willem Jiang <wi...@gmail.com>.
Hi Christian,
I just played with your test case with Camel trunk code.
I found the test can be passed when you remove the route instead of stop
the route.
Please update the setUp() code like this
context.removeRoute(Route2.class.getName());
On 8/23/11 4:36 AM, Christian Müller wrote:
> Hello all!
>
> I'm using Camel 2.6.0 (I got the same result with Camel 2.8.0).
>
> I have a Camel context with two simple routes:
>
> public class Route1 extends RouteBuilder {
> @Override
> public void configure() throws Exception {
>
> from("file://src/test/data?noop=true&initialDelay=5000").routeId(Route1.class.getName())
> .split(body().tokenize(",")) // the content is
> 1,2,3,4,5,6,7,8,9,0
> .to("activemq:queue:foo")
> .end();
> }
> }
>
> public class Route2 extends RouteBuilder {
> @Override
> public void configure() throws Exception {
> from("activemq:queue:foo").routeId(Route2.class.getName())
> .to("activemq:queue:bar");
> }
> }
>
> My Camel context look as following:
>
> <?xml version="1.0" encoding="UTF-8"?>
> <beans xmlns="http://www.springframework.org/schema/beans"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xmlns:camel="http://camel.apache.org/schema/spring"
> xsi:schemaLocation="
> http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans.xsd
> http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd">
>
> <bean id="route1" class="org.apache.cmueller.test.Route1" />
>
> <bean id="route2" class="org.apache.cmueller.test.Route2" />
>
> <bean id="activemq"
> class="org.apache.activemq.camel.component.ActiveMQComponent">
> <property name="connectionFactory" ref="connectionFactory" />
> </bean>
>
> <bean id="connectionFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory">
> <constructor-arg
> value="vm://localhost?broker.persistent=false&broker.useJmx=false"/>
> </bean>
>
> <camel:camelContext trace="true">
> <camel:routeBuilder ref="route1" />
> <camel:routeBuilder ref="route2" />
> </camel:camelContext>
> </beans>
>
>
> I would like to test my Route1 implementation in isolation (without
> Route2). Because of this, I need to stop Route2. But it doesn't work for
> my with the following code:
>
> public class Route1Test extends CamelSpringTestSupport {
>
> @EndpointInject(uri = "mock:foo")
> private MockEndpoint mockEndpointFoo;
>
> @Override
> @Before
> public void setUp() throws Exception {
> super.setUp();
>
> DefaultRoute route2 = (DefaultRoute)
> context.getRoute(Route2.class.getName());
> route2.stop();
>
> context.addRoutes(new RouteBuilder() {
> @Override
> public void configure() throws Exception {
> from("activemq:queue:foo")
> .to(mockEndpointFoo);
> }
> });
> }
>
> @Test
> public void test() throws Exception {
> mockEndpointFoo.expectedBodiesReceived("1", "2", "3", "4", "5",
> "6", "7", "8", "9", "0");
>
> mockEndpointFoo.assertIsSatisfied();
> }
>
> @Override
> protected AbstractApplicationContext createApplicationContext() {
> return new
> ClassPathXmlApplicationContext("META-INF/spring/bundle-context.xml");
> }
> }
>
> Does have anybody an idea what I did wrong?
>
> I attached my Eclipse sample project for convenience.
>
> Best,
> Christian
--
Willem
----------------------------------
FuseSource
Web: http://www.fusesource.com
Blog: http://willemjiang.blogspot.com (English)
http://jnn.javaeye.com (Chinese)
Twitter: willemjiang
Weibo: willemjiang