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

Qpid jms client hangs when used in camel route

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • fuse-7.0
    • jboss-fuse-6.3
    • Camel
    • None
    • % %
    • 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)

      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.

            acosenti Andrea Cosentino
            knetl.j@gmail.com Jakub Knetl (Inactive)
            Viliam Kasala Viliam Kasala
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: