Route started race condition

[Minh Tran <mi...@winning.com.au>]

Hi

I have a camel route that consumes from a topic and sends to a queue. 

from("activemq:topic:mytopic?transacted=true&lazyCreateTransactionManager=true")
.log("${body}")
.to("activemq:queue:myqueue");

I've written some unit tests around it and sometimes it passes and on rare occasions it fails. Unit tests simply just publishes to mytopic and then checks myqueue to see if the message is there.

	@Test
	public void testSend() throws JMSException {
		logger.debug("unit test start");
		producerTemplate.sendBody("hello world");
		TextMessage mesg = (TextMessage) jmsTemplate.receive("myqueue");
		assertEquals("hello world", mesg.getText());
	}
 
Now when I look at the logs, I notice that even though Camel reports the route has started, it doesn't actually consume from the topic until after this. This means that potentially the unit test could publish the message to the topic before the route had registered its own consumer to it. 

Here's a snippet of the logs showing the consumer being created after the route has declared it has started.

2014-04-11 12:12:46,522 [main] INFO  org.apache.camel.spring.SpringCamelContext - Route: route1 started and consuming from: Endpoint[activemq://topic:mytopic?lazyCreateTransactionManager=true&transacted=true]
2014-04-11 12:12:46,522 [main] INFO  org.apache.camel.spring.SpringCamelContext - Total 1 routes, of which 1 is started.
2014-04-11 12:12:46,537 [main] DEBUG au.com.winning.camule.route.JmsTopicTest - unit test start
<snip>
2014-04-11 12:12:46,982 [ActiveMQ VMTransport: vm://localhost#1-1] DEBUG org.apache.activemq.broker.region.AbstractRegion - localhost adding consumer: ID:imacporky.local-57940-1397182366748-3:2:1:1 for destination: topic://mytopic

Important thing to note is that the consumer is created AFTER the route has started and AFTER the unit test has already begun. This is the cause of the race condition. Is this expected behaviour of routes? Shouldn't the consumer be created before declaring the route has started? Btw, this problem only occurs with topics, queues won't see this problem.

I'm using 2.13.0. Thanks.