[rabbitmq-discuss] RabbitMQ/Spring integration - help required

[Alexis Richardson]

Vivek

Have you been able to resolve this issue?

alexis


On Thu, Jun 25, 2009 at 4:18 PM, Vivek Ramesh.
Kubaji<vivek.kubaji at onmobile.com> wrote:
> Hi,
>
>
>
> I'm trying to evaluate RabbitMQ for our project. And I'm using
> Spring-integration framework. From the posts in the forum I ended up using
> the following configuration (jms part):
>
>
>
>       <beans:bean id="amqConnectionFactory"
>
> class="org.apache.qpid.client.AMQConnectionFactory">
>
>             <beans:constructor-arg
>
> value="amqp://guest:guest@/localhost?brokerlist='tcp://localhost:5672'" />
>
>       </beans:bean>
>
>
>
>       <beans:bean id="connectionFactory"
>
> class="org.springframework.jms.connection.SingleConnectionFactory">
>
>             <beans:property name="targetConnectionFactory"
>
> ref="amqConnectionFactory"/>
>
>       </beans:bean>
>
>
>
>       <beans:bean id="jms_QueueWest"
> class="org.apache.qpid.client.AMQQueue">
>
>             <beans:constructor-arg>
>
>                   <beans:bean class="org.apache.qpid.url.AMQBindingURL">
>
>                         <beans:constructor-arg value="${jms.queue1}"/>
>
>                   </beans:bean>
>
>             </beans:constructor-arg>
>
>       </beans:bean>
>
>
>
> and have this in my properties file:
>
>
>
> jms.queue1=direct://rabbit//my.queue1
>
>
>
> I'm running the RabbitMQ broker using the command
> $RABBITMQ_HOME$/sbin/rabbitmq-server.bat. When I start my client application
> I am getting the following error:
>
>
>
> 2009-06-25 19:00:21,192 INFO
>
> org.springframework.jms.listener.DefaultMessageListenerContainer#0-1
>
> [DefaultMessageListenerContainer.refreshConnectionUntilSuccessful] - Could
> not refresh JMS Connection for destination
> 'direct://rabbit/my.queue1/my.queue1?routingkey='my.queue1'' - retrying in
> 5000 ms. Cause: Error creating connection: Unable to Connect
> org.apache.qpid.transport.ConnectionException
>
>         at org.apache.qpid.transport.Connection.close(Connection.java:494)
>
>         at org.apache.qpid.transport.Connection.connect(Connection.java:193)
>
>         at
>
> org.apache.qpid.client.AMQConnectionDelegate_0_10.makeBrokerConnection(AMQConnectionDelegate_0_10.java:161)
>
>         at
>
> org.apache.qpid.client.AMQConnection.makeBrokerConnection(AMQConnection.java:728)
>
>         at
>
> org.apache.qpid.client.AMQConnection.<init>(AMQConnection.java:520)
>
>         at
>
> org.apache.qpid.client.AMQConnectionFactory.createConnection(AMQConnectionFactory.java:276)
>
>         at
>
> org.springframework.jms.connection.SingleConnectionFactory.doCreateConnection(SingleConnectionFactory.java:343)
>
>         at
>
> org.springframework.jms.connection.SingleConnectionFactory.initConnection(SingleConnectionFactory.java:290)
>
>         at
>
> org.springframework.jms.connection.SingleConnectionFactory.createConnection(SingleConnectionFactory.java:227)
>
>         at
>
> org.springframework.jms.support.JmsAccessor.createConnection(JmsAccessor.java:184)
>
>         at
>
> org.springframework.jms.listener.AbstractJmsListeningContainer.createSharedConnection(AbstractJmsListeningContainer.java:378)
>
>         at
>
> org.springframework.jms.listener.AbstractJmsListeningContainer.refreshSharedConnection(AbstractJmsListeningContainer.java:363)
>
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer.refreshConnectionUntilSuccessful(DefaultMessageListenerContainer.java:785)
>
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer.recoverAfterListenerSetupFailure(DefaultMessageListenerContainer.java:767)
>
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:898)
>
>         at java.lang.Thread.run(Thread.java:619)
>
> Caused by: org.apache.qpid.transport.ConnectionException
>
>         at
>
> org.apache.qpid.transport.Connection.exception(Connection.java:405)
>
>         at
>
> org.apache.qpid.transport.network.Assembler.exception(Assembler.java:108)
>
>         at
>
> org.apache.qpid.transport.network.InputHandler.exception(InputHandler.java:196)
>
>         at
>
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:146)
>
>         ... 1 more
>
> Caused by: java.lang.IllegalStateException
>
>         at
>
> org.apache.qpid.transport.network.InputHandler.next(InputHandler.java:190)
>
>         at
>
> org.apache.qpid.transport.network.InputHandler.received(InputHandler.java:103)
>
>         at
>
> org.apache.qpid.transport.network.InputHandler.received(InputHandler.java:42)
>
>         at
>
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:128)
>
>         ... 1 more
>
>
>
> Seeing the error I feel I have done some stupid mistake . Somebody please
> help me ...
>
>
>
> Thanks in advance.
>
>
>
> Regards,
>
> Vivek
>
>
>
>
>
> Regards,
>
> Vivek Kubaji
>
> Mail       : vivek.kubaji at onmobile.com
>
> Mobile  : 9880199884
>
> Ext          : 6147
>
>
>
> ==============================
> DISCLAIMER: The information in this message is confidential and may be
> legally privileged. It is intended solely for the addressee. Access to this
> message by anyone else is unauthorized. If you are not the intended
> recipient, any disclosure, copying, or distribution of the message, or any
> action or omission taken by you in reliance on it, is prohibited and may be
> unlawful. Please immediately contact the sender if you have received this
> message in error. Further, this e-mail may contain viruses and all
> reasonable precaution to minimize the risk arising there from is taken by
> OnMobile. OnMobile is not liable for any damage sustained by you as a result
> of any virus in this e-mail. All applicable virus checks should be carried
> out by you before opening this e-mail or any attachment thereto.
> Thank you - OnMobile Global Limited.
> ==============================
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>