FYI, I got some advice from stackoverflow to change the bean id below from "amqpConnection" to "amqp" (matching the 'from' and 'to' prefixes in the route below) and that got me past this immediate problem. I submitted a JIRA for this issue.
-Steve > -----Original Message----- > From: Steve Huston > Sent: Thursday, October 08, 2015 1:47 PM > To: users@camel.apache.org > Subject: Trouble getting AMQP going > > I am trying to use AMQP queues as both the start and end of a route. I am > having trouble getting this to work, following the example at > http://camel.apache.org/amqp.html > > Could someone please point me in the right direction? > Thank you, > -Steve Huston > > I am deploying this in a blueprint container in karaf. > > My setup is: > > <bean id="amqpConnectionFactory" > class="org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl" > factory-method="createFromURL"> > <argument value="${IssBroker.url}" /> > </bean> > > <bean id="amqpConnection" > class="org.apache.camel.component.jms.JmsComponent" > > <property name="connectionFactory" ref="amqpConnectionFactory"/> > </bean> > > ... > > <route> > <from uri="amqp:{{IssFrom.queue}}"/> > <process ref="issPreprocessor"/> > <unmarshal ref="IssRequest"/> > <process ref="webServiceProcessor"/> > <to uri="webService"/> > <process ref="packageWebServiceReplyForIss"/> > <to uri="amqp:{{IssTo.queue}}"/> > </route> > > > When I start this in karaf I get: > 2015-10-08 13:34:00,968 | ERROR | nsole user karaf | BlueprintCamelContext > | 109 - org.apache.camel.camel-blueprint - 2.15.3 | Error occurred during > starting Camel: CamelContext(myCamelContext) due connectionFactory > must be specified > > java.lang.IllegalArgumentException: connectionFactory must be specified > at > org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:293) > at > org.apache.camel.component.jms.JmsConfiguration.createConnectionFactor > y(JmsConfiguration.java:1131) > at > org.apache.camel.component.jms.JmsConfiguration.getConnectionFactory(J > msConfiguration.java:485) > at > org.apache.camel.component.jms.JmsConfiguration.createListenerConnecti > onFactory(JmsConfiguration.java:1140) > at > org.apache.camel.component.jms.JmsConfiguration.getListenerConnectionF > actory(JmsConfiguration.java:504) > at > org.apache.camel.component.jms.JmsConfiguration.configureMessageListe > nerContainer(JmsConfiguration.java:967) > at > org.apache.camel.component.jms.JmsConfiguration.createMessageListener > Container(JmsConfiguration.java:448) > at > org.apache.camel.component.jms.JmsEndpoint.createMessageListenerCont > ainer(JmsEndpoint.java:184) > at > org.apache.camel.component.jms.JmsEndpoint.createConsumer(JmsEndpoi > nt.java:179) > at > org.apache.camel.component.jms.JmsEndpoint.createConsumer(JmsEndpoi > nt.java:71) > ... >
