Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

To have using topics working with camel-amqp you need to configure the component to use "topic://" as topic prefix, as shown below

Code Block
 <bean id="amqpConnectionamqp" class="org.apache.camel.component.jms.JmsComponent" >
        <property name="connectionFactory">
          <bean class="org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl" factory-method="createFromURL">
                        <constructor-arg index="0" type="java.lang.String" value="amqp://localhost:5672" />
            <property name="topicPrefix" value="topic://" />  <!-- only necessary when connecting to ActiveMQ over AMQP 1.0 -->
           </bean>
        </property>
    </bean>

...