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

[krv]

Hi Folks,

Thanks for your valuable suggestions, I was able to advance a bit.
Nevertheless I'm still stuck with getting 'rabbitmqctl.bat' working (Windows
env and user is neither 'rabbitmq' nor 'root'). I was caught up with
something else so couldn't look much into this. Will work on this today and
try to get it working.

Hope RabbitMQ does not have any issue running on Windows, cuz most of the
posts speak of running on Linux.

Regards,
Vivek


Alexis Richardson-4 wrote:
> 
> 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
>>
>>
> 
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
> 
> 

-- 
View this message in context: http://www.nabble.com/RabbitMQ-Spring-integration---help-required-tp24203688p24284545.html
Sent from the RabbitMQ mailing list archive at Nabble.com.