Uploaded image for project: 'Red Hat Fuse'
  1. Red Hat Fuse
  2. ENTESB-6033

Qpid jms client hangs when used in camel route

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Done
    • Affects Version/s: jboss-fuse-6.3
    • Fix Version/s: fuse-7.0
    • Component/s: Camel
    • Labels:
      None
    • Environment:

      JBoss Fuse 6.3.0.redhat-159

    • Steps to Reproduce:
      Hide
      1. start fuse and amq
      2. install camel-amqp feature (it contains qpid-jms-client)
      3. deploy following camel route

        <?xml version="1.0" encoding="UTF-8"?>
        <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
        	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0"
        	xsi:schemaLocation="
                 http://www.osgi.org/xmlns/blueprint/v1.0.0 https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
                 http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd
                 http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0 http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.1.0.xsd">
         
        	<bean id="amqpCf" class="org.apache.qpid.jms.JmsConnectionFactory">
        		<property name="remoteURI" value="amqp://localhost:5672" />
        		<property name="username" value="admin" />
        		<property name="password" value="admin" />
        	</bean>
         
        	<bean id="amqpConfig" class="org.apache.camel.component.jms.JmsConfiguration">
        		<property name="connectionFactory" ref="amqpCf" />
        	</bean>
         
        	<bean id="amqpartemis" class="org.apache.camel.component.jms.JmsComponent">
        		<property name="configuration" ref="amqpConfig" />
        	</bean>
         
            <service ref="amqpCf" interface="javax.jms.ConnectionFactory"/>
         
        	<bean id="fuseCf" class="org.apache.activemq.ActiveMQConnectionFactory">
        		<property name="brokerURL" value="tcp://localhost:61617" />
        		<property name="userName" value="admin" />
        		<property name="password" value="admin" />
        	</bean>
         
        	<bean id="fuseJmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
        		<property name="connectionFactory" ref="fuseCf" />
        	</bean>
         
        	<bean id="jmsfuse" class="org.apache.activemq.camel.component.ActiveMQComponent">
        		<property name="configuration" ref="fuseJmsConfig" />
        	</bean>
         
        	<camelContext xmlns="http://camel.apache.org/schema/blueprint"
        		id="fuse-artemis">
        		<route id="to-fuse">
        			<from uri="amqpartemis:artemis2" />
        			<to uri="jmsfuse:queue:amq2" />
        		</route>
        	</camelContext>
        

      4. start the bundle with route (karaf shell will hang)
      Show
      start fuse and amq install camel-amqp feature (it contains qpid-jms-client) deploy following camel route <?xml version="1.0" encoding="UTF-8"?> <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0" xsi:schemaLocation=" http://www.osgi.org/xmlns/blueprint/v1.0.0 https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0 http://aries.apache.org/schemas/blueprint-cm/blueprint-cm-1.1.0.xsd">   <bean id="amqpCf" class="org.apache.qpid.jms.JmsConnectionFactory"> <property name="remoteURI" value="amqp://localhost:5672" /> <property name="username" value="admin" /> <property name="password" value="admin" /> </bean>   <bean id="amqpConfig" class="org.apache.camel.component.jms.JmsConfiguration"> <property name="connectionFactory" ref="amqpCf" /> </bean>   <bean id="amqpartemis" class="org.apache.camel.component.jms.JmsComponent"> <property name="configuration" ref="amqpConfig" /> </bean>   <service ref="amqpCf" interface="javax.jms.ConnectionFactory"/>   <bean id="fuseCf" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://localhost:61617" /> <property name="userName" value="admin" /> <property name="password" value="admin" /> </bean>   <bean id="fuseJmsConfig" class="org.apache.camel.component.jms.JmsConfiguration"> <property name="connectionFactory" ref="fuseCf" /> </bean>   <bean id="jmsfuse" class="org.apache.activemq.camel.component.ActiveMQComponent"> <property name="configuration" ref="fuseJmsConfig" /> </bean>   <camelContext xmlns="http://camel.apache.org/schema/blueprint" id="fuse-artemis"> <route id="to-fuse"> <from uri="amqpartemis:artemis2" /> <to uri="jmsfuse:queue:amq2" /> </route> </camelContext> start the bundle with route (karaf shell will hang)

      Description

      I created simple route between Fuse 6.3 and AMQ 7. The route is consuming from AMQ7 queue and sending messages to Fuse. I used qpid jms client for accessing AMQ7 queue as recommended in ENTESB-4852. But when I start the bundle with the route then Karaf shell hangs on start command. It can be interrupted with CTRL-C signal but the route is not consuming from the AMQ7.

        Gliffy Diagrams

          Attachments

            Issue Links

              Activity

                People

                • Assignee:
                  oscerd Andrea Cosentino
                  Reporter:
                  jknetl Jakub Knetl
                  Tester:
                  Viliam Kasala
                • Votes:
                  0 Vote for this issue
                  Watchers:
                  3 Start watching this issue

                  Dates

                  • Created:
                    Updated:
                    Resolved: