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>
To: 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> 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
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
