Camel azure service bus queue

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Camel azure service bus queue

satishbhuria
Hi Team,

I am working on a project where i have to access azure service bus queue and read write message to queue.

I have written camel route for the same but is giving me error below.

org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Failed to create connection to: amqp://dummy-queue; nested exception is io.netty.channel.ConnectTimeoutException: connection timed out

Let me know where i am wrong.

Below is the code i have put in my project for configuration of jms connection factory

  <bean id="jmsConnectionFactory" class="org.apache.qpid.jms.JmsConnectionFactory">
        <property name="remoteURI" value="amqp://${service_bus.uri}" />
        <property name="username" value="${service_bus.username}" />
        <property name="password" value="${service_bus.password}" />
        <property name="receiveLocalOnly" value="true" />
    </bean>
   
    <bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration" >
        <property name="connectionFactory" ref="jmsConnectionFactory" />
        <property name="cacheLevelName" value="CACHE_AUTO" />
    </bean>
    <bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent">
        <property name="configuration" ref="jmsConfig" />
    </bean>

and virtual host is get appended to service bus uri. please suggest

Thanks

satish
Reply | Threaded
Open this post in threaded view
|  
Report Content as Inappropriate

Re: Camel azure service bus queue

pontus.ullgren
Hi,

Try chaning your remoteUri for the JmsConnectionFactory to be amqps instead.
Also add amqp.idleTimeout=120000

<property name="remoteURI"
          value="amqps://${service_bus.uri}?amqp.idleTimeout=120000" />

If this does not work please provide more info on what your properties
especially service_bus.uri is set to.

Fredrik J├Ânsson has writen a good blog on the topic of connecting to Azure
Service Bus using camel
https://www.kth.se/blogs/1337/2016/11/using-apache-camel-with-azure-service-bus/

Best regards
Pontus Ullgren





On Wed, 11 Jan 2017 at 09:45 satishbhuria <[hidden email]> wrote:

> Hi Team,
>
> I am working on a project where i have to access azure service bus queue
> and
> read write message to queue.
>
> I have written camel route for the same but is giving me error below.
>
> org.springframework.jms.UncategorizedJmsException: Uncategorized exception
> occured during JMS processing; nested exception is javax.jms.JMSException:
> Failed to create connection to: amqp://dummy-queue; nested exception is
> io.netty.channel.ConnectTimeoutException: connection timed out
>
> Let me know where i am wrong.
>
> Below is the code i have put in my project for configuration of jms
> connection factory
>
>   <bean id="jmsConnectionFactory"
> class="org.apache.qpid.jms.JmsConnectionFactory">
>         <property name="remoteURI" value="amqp://${service_bus.uri}" />
>         <property name="username" value="${service_bus.username}" />
>         <property name="password" value="${service_bus.password}" />
>         <property name="receiveLocalOnly" value="true" />
>     </bean>
>
>     <bean id="jmsConfig"
> class="org.apache.camel.component.jms.JmsConfiguration" >
>         <property name="connectionFactory" ref="jmsConnectionFactory" />
>         <property name="cacheLevelName" value="CACHE_AUTO" />
>     </bean>
>     <bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent">
>         <property name="configuration" ref="jmsConfig" />
>     </bean>
>
> and virtual host is get appended to service bus uri. please suggest
>
> Thanks
>
> satish
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Camel-azure-service-bus-queue-tp5792380.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
Loading...