No reply received - perhaps a timeout in the template?

[reetesh sikarwar]

Hi ,

I am getting the following machine when I tried RabbitMQ with two different machine
While on local machine is working fine. Can somebody know about that issue?

Caused by: org.springframework.remoting.RemoteProxyFailureException: No reply received - perhaps a timeout in the t
emplate?
        at org.springframework.amqp.remoting.client.AmqpClientInterceptor.invoke(AmqpClientInterceptor.java:60)
        at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179
)
        at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207)
        at com.sun.proxy.$Proxy10.checkNoOfFailedAttempt(Unknown Source)

Regards,
Reetesh

[Michael Klishin]

What is in RabbitMQ log file?

You may be connecting with the default user (guest/guest). It can only connect from localhost. See
http://www.rabbitmq.com/access-control.html (creating a separate user is the right thing to do). 
--
MK

Staff Software Engineer, Pivotal/RabbitMQ

[reetesh sikarwar]

Thanks MK.

Whenever I tried to connect I found following error in log.

=ERROR REPORT==== 19-Feb-2015::10:05:59 ===
Channel error on connection <0.1474.0> (172.16.206.139:59826 -> 172.16.206.154:5672, vhost: '/', user: 'reetesh'), channel 13:
{amqp_error,not_found,"no queue 'identity.queue' in vhost '/'",
            'queue.declare'}

Full RabbitMQ log:--

------------------------------------------
=INFO REPORT==== 19-Feb-2015::09:53:36 ===
Starting RabbitMQ 3.4.1 on Erlang 17.3
Copyright (C) 2007-2014 GoPivotal, Inc.
Licensed under the MPL.  See http://www.rabbitmq.com/

=INFO REPORT==== 19-Feb-2015::09:53:36 ===
node           : rabbit@RC4B2-FTHNQ1S-D
home dir       : <<user-home>>
config file(s) : <<user-home>>/AppData/Roaming/RabbitMQ/rabbitmq.config
cookie hash    : ikAzK73Ht2Im2vHeSJFakw==
log            : <<user-home>>/AppData/Roaming/RabbitMQ/log/rab...@RC4B2-FTHNQ1S-D.log
sasl log       : <<user-home>>/AppData/Roaming/RabbitMQ/log/rab...@RC4B2-FTHNQ1S-D-sasl.log
database dir   : <<user-home>>/AppData/Roaming/RabbitMQ/db/rabbit@RC4B2-FTHNQ1S-D-mnesia

=WARNING REPORT==== 19-Feb-2015::09:53:36 ===
Kernel poll (epoll, kqueue, etc) is disabled. Throughput and CPU utilization may worsen.

=INFO REPORT==== 19-Feb-2015::09:53:38 ===
Limiting to approx 8092 file handles (7280 sockets)

=INFO REPORT==== 19-Feb-2015::09:53:38 ===
Memory limit set to 2431MB of 6077MB total.

=INFO REPORT==== 19-Feb-2015::09:53:38 ===
Disk free limit set to 50MB

=INFO REPORT==== 19-Feb-2015::09:53:38 ===
msg_store_transient: using rabbit_msg_store_ets_index to provide index

=INFO REPORT==== 19-Feb-2015::09:53:38 ===
msg_store_persistent: using rabbit_msg_store_ets_index to provide index

=WARNING REPORT==== 19-Feb-2015::09:53:38 ===
msg_store_persistent: rebuilding indices from scratch

=INFO REPORT==== 19-Feb-2015::09:53:39 ===
started TCP Listener on [::]:5672

=INFO REPORT==== 19-Feb-2015::09:53:39 ===
started TCP Listener on 0.0.0.0:5672

=INFO REPORT==== 19-Feb-2015::09:53:39 ===
Management plugin started. Port: 15672

=INFO REPORT==== 19-Feb-2015::09:53:39 ===
Statistics database started.

=INFO REPORT==== 19-Feb-2015::09:53:39 ===
Server startup complete; 6 plugins started.
 * rabbitmq_management
 * rabbitmq_web_dispatch
 * webmachine
 * mochiweb
 * rabbitmq_management_agent
 * amqp_client

=INFO REPORT==== 19-Feb-2015::09:56:12 ===
Creating user 'reetesh'

=INFO REPORT==== 19-Feb-2015::09:56:14 ===
Setting user tags for user 'reetesh' to [administrator]

=INFO REPORT==== 19-Feb-2015::09:56:19 ===
Setting permissions for 'reetesh' in '/' to '.*', '.*', '.*'

=INFO REPORT==== 19-Feb-2015::10:00:47 ===
accepting AMQP connection <0.1474.0> (172.16.206.139:59826 -> 172.16.206.154:5672)

=ERROR REPORT==== 19-Feb-2015::10:05:59 ===
Channel error on connection <0.1474.0> (172.16.206.139:59826 -> 172.16.206.154:5672, vhost: '/', user: 'reetesh'), channel 13:
{amqp_error,not_found,"no queue 'identity.queue' in vhost '/'",
            'queue.declare'}

=WARNING REPORT==== 19-Feb-2015::10:06:07 ===
closing AMQP connection <0.1474.0> (172.16.206.139:59826 -> 172.16.206.154:5672):
connection_closed_abruptly

=INFO REPORT==== 19-Feb-2015::10:08:16 ===
accepting AMQP connection <0.2268.0> (172.16.206.139:60603 -> 172.16.206.154:5672)

=WARNING REPORT==== 19-Feb-2015::10:12:50 ===
closing AMQP connection <0.2268.0> (172.16.206.139:60603 -> 172.16.206.154:5672):
connection_closed_abruptly
------------------------------------------

[Michael Klishin]

What does your code look like? That is a channel error, presumably due to a failing passive declare.

MK

[reetesh sikarwar]

For RPC call:-

At server side:-

<rabbit:connection-factory id="connectionFactory" host="172.16.206.154" username="reetesh" password="reetesh"/> />
    <rabbit:admin id="amqpAdmin" connection-factory="connectionFactory"/>
    <rabbit:template id="template" connection-factory="connectionFactory" />
   
        
    <rabbit:queue name=".queue" />
   
    <rabbit:direct-exchange name="identity.exchange">
        <rabbit:bindings>
            <rabbit:binding queue="identity.queue"  key="identity.binding"/>
        </rabbit:bindings>
    </rabbit:direct-exchange>

    <bean id="idenityListener"
        class="org.springframework.amqp.remoting.service.AmqpInvokerServiceExporter">
        <property name="serviceInterface" value="<<package>.AA" />
        <property name="service" ref="AAProxy" />
        <property name="amqpTemplate" ref="template" />
    </bean>
            
    <rabbit:listener-container connection-factory="connectionFactory">
        <rabbit:listener ref="idenityListener" queue-names="identity.queue" />
    </rabbit:listener-container>


At client side:-

<rabbit:connection-factory id="connectionFactory" host="172.16.206.154" username="reetesh" password="reetesh"/> />
    <rabbit:admin connection-factory="connectionFactory" />
        
     
    <bean id="identityClient"
        class="org.springframework.amqp.remoting.client.AmqpProxyFactoryBean">
        <property name="amqpTemplate" ref="identityTemplate" />
        <property name="serviceInterface" value="<<package>.AA" />
    </bean>
   
    <bean id="AAProxy" class="<xx>.AAProxy" init-method="init" />
   
    <rabbit:template id="identityTemplate" connection-factory="connectionFactory" reply-timeout="2000"
        routing-key="identity.binding" exchange="identity.exchange" />

Thease xml load from java file to call server method.

[Michael Klishin]

 On 19 February 2015 at 12:48:34, reetesh sikarwar (sikarwa...@gmail.com) wrote:
> For RPC call:-
>
> At server side:-
>

> > username="reetesh" password="reetesh"/> />

Spring AMQP questions should be posted to Stack Overflow with the tag spring-amqp. Sorry
but that project us not maintained by us.

[Gary Russell]

<rabbit:queue name=".queue" />
    
    <rabbit:direct-exchange name="identity.exchange">
        <rabbit:bindings>
            <rabbit:binding queue="identity.queue"  key="identity.binding"/>
        </rabbit:bindings>
    </rabbit:direct-exchange>

You have a typo in the queue name (.queue instead of identity.queue).

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To post to this group, send an email to rabbitm...@googlegroups.com.

For more options, visit https://groups.google.com/d/optout.