Yeah, I should work.
-- Willem Jiang FuseSource Web: http://www.fusesource.com (http://www.fusesource.com/) Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn.javaeye.com (http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: willemjiang On Monday, September 3, 2012 at 4:27 AM, Sura Monday wrote: > I tried this: > ConnectionFactory connectionFactory = new > ActiveMQConnectionFactory("tcp://localhost:61616"); > camel.addComponent("jms", > JmsComponent.jmsComponentAutoAcknowledge(connectionFactory)); > > doesn't this set up a connection factory? > > > I have not worked with spring, so I am trying to see how this could be done > in Java only. > > > > ________________________________ > From: Claus Ibsen <claus.ib...@gmail.com (mailto:claus.ib...@gmail.com)> > To: users@camel.apache.org (mailto:users@camel.apache.org) > Sent: Sunday, September 2, 2012 8:12 PM > Subject: Re: problem with ActiveMQ component > > Hi > > You need to setup a connection factory. > > This page tells you how to setup AMQ, but with XML though > http://camel.apache.org/activemq > > See how we setup AMQ in camel-jms unit tests > https://svn.apache.org/repos/asf/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/CamelJmsTestHelper.java > https://svn.apache.org/repos/asf/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsAutoStartupTest.java > > > On Sun, Sep 2, 2012 at 7:02 AM, Sura Monday <sura.mon...@yahoo.com > (mailto:sura.mon...@yahoo.com)> wrote: > > Hi All, > > > > I have been trying to add a simple activeMQ component to my camel context. > > Here's my code: > > > > String url = "tcp://localhost:61616?broker.persistent=false"; > > camel.addComponent("jms", activeMQComponent(url)); > > > > /* Create the routes */ > > camel.addRoutes(new BdiRouteBuilder() { > > > > public void configure() { > > > > from("jms:topic:chat") > > .to("file://data/inbox?fileName=t.txt"); > > } > > }); > > > > I have correctly go the server running at localhost:61616 and tested it > > with a simple activeMQ client. > > > > However, when I try to use the above route, I get an exception, which is > > shown below. Can somebody tell me what I am doing wrong? I guess it has got > > something to do with a missing connection factor ('Caused by: > > java.lang.IllegalArgumentException: connectionFactory must be specified'). > > But not sure how to fix this. > > > > > > Error occurred while running main from: org.apache.camel.spring.Main > > java.lang.reflect.InvocationTargetException > > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > > at > > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) > > at > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) > > at java.lang.reflect.Method.invoke(Method.java:597) > > at org.apache.camel.maven.RunMojo$1.run(RunMojo.java:415) > > at java.lang.Thread.run(Thread.java:619) > > Caused by: org.apache.camel.RuntimeCamelException: > > java.lang.IllegalArgumentException: connectionFactory must be specified > > at > > org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1140) > > at > > org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:103) > > at > > org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:237) > > at > > org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:97) > > at > > org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:303) > > at > > org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:911) > > at > > org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:428) > > at > > org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:139) > > at > > org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:93) > > at > > org.apache.camel.spring.Main.createDefaultApplicationContext(Main.java:219) > > at org.apache.camel.spring.Main.doStart(Main.java:173) > > at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:65) > > at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:52) > > at org.apache.camel.impl.MainSupport.run(MainSupport.java:114) > > at org.apache.camel.impl.MainSupport.run(MainSupport.java:291) > > at org.apache.camel.spring.Main.main(Main.java:97) > > ... 6 more > > Caused by: java.lang.IllegalArgumentException: connectionFactory must be > > specified > > at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:276) > > at > > org.apache.camel.component.jms.JmsConfiguration.createConnectionFactory(JmsConfiguration.java:1041) > > at > > org.apache.camel.component.jms.JmsConfiguration.getConnectionFactory(JmsConfiguration.java:403) > > at > > org.apache.camel.component.jms.JmsConfiguration.createListenerConnectionFactory(JmsConfiguration.java:1050) > > at > > org.apache.camel.component.jms.JmsConfiguration.getListenerConnectionFactory(JmsConfiguration.java:422) > > at > > org.apache.camel.component.jms.JmsConfiguration.configureMessageListenerContainer(JmsConfiguration.java:877) > > at > > org.apache.camel.component.jms.JmsConfiguration.createMessageListenerContainer(JmsConfiguration.java:375) > > at > > org.apache.camel.component.jms.JmsEndpoint.createMessageListenerContainer(JmsEndpoint.java:190) > > at > > org.apache.camel.component.jms.JmsEndpoint.createConsumer(JmsEndpoint.java:169) > > at > > org.apache.camel.component.jms.JmsEndpoint.createConsumer(JmsEndpoint.java:74) > > at > > org.apache.camel.impl.EventDrivenConsumerRoute.addServices(EventDrivenConsumerRoute.java:61) > > at > > org.apache.camel.impl.DefaultRoute.onStartingServices(DefaultRoute.java:75) > > at org.apache.camel.impl.RouteService.warmUp(RouteService.java:118) > > at > > org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:1694) > > at > > org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:1620) > > at > > org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:1419) > > at > > org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:1314) > > at > > org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:1213) > > at > > org.apache.camel.spring.SpringCamelContext.doStart(SpringCamelContext.java:164) > > at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:65) > > at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:52) > > at > > org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:1191) > > at > > org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:203) > > at > > org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:101) > > > > > > /Sura > > > > -- > Claus Ibsen > ----------------- > FuseSource > Email: cib...@fusesource.com (mailto:cib...@fusesource.com) > Web: http://fusesource.com > Twitter: davsclaus, fusenews > Blog: http://davsclaus.com > Author of Camel in Action: http://www.manning.com/ibsen
