I have a simple forwarder application that has a single route:
from(input).to(output)
When input is activemq:somequeue and output is file:/tmp/blah, the app
works fine, reading messages from my queue and writing to files.
If I switch them around and put the input as the file:/tmp/blah and output
as the queue, the application returns to the terminal immediately and doesnt
start consuming...
Here is the output, There is a bunch of files in /tmp/blah but it doesnt
attempt to consume them... any ideas why?
Feb 16, 2011 4:16:03 PM
org.springframework.context.support.AbstractApplicationContext
prepareRefresh
INFO: Refreshing
org.springframework.context.support.ClassPathXmlApplicationContext@2d09b23b:
startup date [Wed Feb 16 16:16:03 GMT 2011]; root of context hierarchy
JRebel-Spring: Monitoring Spring bean definitions in
'/Users/tom/bbc/otg_wfe/ispy_agent_jms/trunk/target/classes/appContext.xml'.
Feb 16, 2011 4:16:03 PM
org.springframework.beans.factory.xml.XmlBeanDefinitionReader
loadBeanDefinitions
INFO: Loading XML bean definitions from class path resource [appContext.xml]
Feb 16, 2011 4:16:04 PM
org.springframework.beans.factory.support.DefaultListableBeanFactory
preInstantiateSingletons
INFO: Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@715d63da:
defining beans
[activemq,myConfigDelivery,jmsTransactionManagerDelivery,jmsCachingConnectionFactoryDelivery,jmsConnectionFactoryDelivery,redeliveryPolicyDelivery,activemq-int,intTransactionManager,intConnectionFactory];
root of factory hierarchy
16:16:04.307 [agentsmith.GoCamel.main()] INFO agentsmith.AkkaAgent - Set
broker URL to: tcp://localhost:61616
Feb 16, 2011 4:16:04 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Apache Camel 2.5.0 (CamelContext: camel-1) is starting
Feb 16, 2011 4:16:04 PM org.apache.camel.impl.DefaultCamelContext
createManagementStrategy
INFO: JMX enabled. Using ManagedManagementStrategy.
Feb 16, 2011 4:16:05 PM
org.apache.camel.impl.converter.AnnotationTypeConverterLoader load
INFO: Found 7 packages with 19 @Converter classes to load
Feb 16, 2011 4:16:05 PM
org.apache.camel.impl.converter.BaseTypeConverterRegistry loadTypeConverters
INFO: Loaded 166 type converters in 0.563 seconds
Feb 16, 2011 4:16:06 PM org.apache.camel.impl.DefaultCamelContext
doStartOrResumeRouteConsumers
INFO: Route: route1 started and consuming from: Endpoint[file://tmp/blah]
Feb 16, 2011 4:16:06 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Total 1 routes, of which 1 is started.
Feb 16, 2011 4:16:06 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Apache Camel 2.5.0 (CamelContext: camel-1) started in 1.465 seconds
[INFO]
------------------------------------------------------------------------
[INFO] BUILD SUCCESSFUL
[INFO]
------------------------------------------------------------------------
[INFO] Total time: 7 seconds
[INFO] Finished at: Wed Feb 16 16:16:06 GMT 2011
[INFO] Final Memory: 45M/265M
[INFO]
------------------------------------------------------------------------
hanoman:trunk tom$
When I go from Queue => File, I get...
Feb 16, 2011 4:20:13 PM
org.springframework.context.support.AbstractApplicationContext
prepareRefresh
INFO: Refreshing
org.springframework.context.support.ClassPathXmlApplicationContext@3572cc99:
startup date [Wed Feb 16 16:20:13 GMT 2011]; root of context hierarchy
JRebel-Spring: Monitoring Spring bean definitions in
'/Users/tom/bbc/otg_wfe/ispy_agent_jms/trunk/target/classes/appContext.xml'.
Feb 16, 2011 4:20:13 PM
org.springframework.beans.factory.xml.XmlBeanDefinitionReader
loadBeanDefinitions
INFO: Loading XML bean definitions from class path resource [appContext.xml]
Feb 16, 2011 4:20:14 PM
org.springframework.beans.factory.support.DefaultListableBeanFactory
preInstantiateSingletons
INFO: Pre-instantiating singletons in
org.springframework.beans.factory.support.DefaultListableBeanFactory@75d8362:
defining beans
[activemq,myConfigDelivery,jmsTransactionManagerDelivery,jmsCachingConnectionFactoryDelivery,jmsConnectionFactoryDelivery,redeliveryPolicyDelivery,activemq-int,intTransactionManager,intConnectionFactory];
root of factory hierarchy
16:20:14.736 [agentsmith.GoCamel.main()] INFO agentsmith.AkkaAgent - Set
broker URL to: tcp://nm-int-wfe-mq-a.bbc.redbeemedia.net:61616
Feb 16, 2011 4:20:15 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Apache Camel 2.5.0 (CamelContext: camel-1) is starting
Feb 16, 2011 4:20:15 PM org.apache.camel.impl.DefaultCamelContext
createManagementStrategy
INFO: JMX enabled. Using ManagedManagementStrategy.
Feb 16, 2011 4:20:15 PM
org.apache.camel.impl.converter.AnnotationTypeConverterLoader load
INFO: Found 7 packages with 19 @Converter classes to load
Feb 16, 2011 4:20:15 PM
org.apache.camel.impl.converter.BaseTypeConverterRegistry loadTypeConverters
INFO: Loaded 166 type converters in 0.489 seconds
Feb 16, 2011 4:20:16 PM
org.springframework.jms.connection.SingleConnectionFactory initConnection
INFO: Established shared JMS Connection: ActiveMQConnection
{id=ID:hanoman.national.core.bbc.co.uk-63375-1297873216544-0:0,clientId=null,started=false}
Feb 16, 2011 4:20:16 PM org.apache.camel.impl.DefaultCamelContext
doStartOrResumeRouteConsumers
INFO: Route: route1 started and consuming from:
Endpoint[activemq://topic:ispy]
Feb 16, 2011 4:20:16 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Total 1 routes, of which 1 is started.
Feb 16, 2011 4:20:16 PM org.apache.camel.impl.DefaultCamelContext start
INFO: Apache Camel 2.5.0 (CamelContext: camel-1) started in 1.767 seconds
16:20:17.783 [DefaultMessageListenerContainer-1] INFO agentsmith.AkkaAgent
- Message in: JmsMessage: ActiveMQTextMessage {commandId = 6,
responseRequired = false, messageId =
ID:vp-int-wfe-b-56866-1297782166935-0:134363:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:vp-int-wfe-b-56866-1297782166935-0:134363:1:1, destination =
topic://ispy, transactionId =
TX:ID:vp-int-wfe-b-56866-1297782166935-0:134363:1, expiration = 0, timestamp
= 1297873215471, arrival = 0, brokerInTime = 1297873215474, brokerOutTime =
1297873215476, 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 = null, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text =
{"wfe_version":"R10.10.14","uuid":"A2F980DE-3...70806C98"}
}
16:20:18.009 [DefaultMessageListenerContainer-1] INFO agentsmith.AkkaAgent
- Message in: JmsMessage: ActiveMQTextMessage {commandId = 6,
responseRequired = false, messageId =
ID:vp-int-wfe-b-56866-1297782166935-0:134364:1:1:1, originalDestination =
null, originalTransactionId = null, producerId =
ID:vp-int-wfe-b-56866-1297782166935-0:134364:1:1, destination =
topic://ispy, transactionId =
TX:ID:vp-int-wfe-b-56866-1297782166935-0:134364:1, expiration = 0, timestamp
= 1297873215487, arrival = 0, brokerInTime = 1297873215489, brokerOutTime =
1297873215490, 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 = null, readOnlyProperties = true, readOnlyBody = true,
droppable = false, text =
{"broadcast_pid":"p004jhvk","wfe_version":"R1...70806C98"}
}
