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

[Alexis Richardson]

Vivek

Did you get this working?  Let us know - there are lots of people here
who know about rabbitmqctl.

Yes, RabbitMQ works *just fine* on Windows and if you have any
problems with that - please tell us.

alexis


On Wed, Jul 1, 2009 at 6:52 AM, krv<vivek.kubaji at onmobile.com> wrote:
>
> 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.
>
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>