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.createConnectionFactory(JmsConfiguration.java:1131)
        at 
org.apache.camel.component.jms.JmsConfiguration.getConnectionFactory(JmsConfiguration.java:485)
        at 
org.apache.camel.component.jms.JmsConfiguration.createListenerConnectionFactory(JmsConfiguration.java:1140)
        at 
org.apache.camel.component.jms.JmsConfiguration.getListenerConnectionFactory(JmsConfiguration.java:504)
        at 
org.apache.camel.component.jms.JmsConfiguration.configureMessageListenerContainer(JmsConfiguration.java:967)
        at 
org.apache.camel.component.jms.JmsConfiguration.createMessageListenerContainer(JmsConfiguration.java:448)
        at 
org.apache.camel.component.jms.JmsEndpoint.createMessageListenerContainer(JmsEndpoint.java:184)
        at 
org.apache.camel.component.jms.JmsEndpoint.createConsumer(JmsEndpoint.java:179)
        at 
org.apache.camel.component.jms.JmsEndpoint.createConsumer(JmsEndpoint.java:71)
...


Reply via email to