Pika Blocking Connection timeout at 180 sec max

[Amulya Sharma]

https://github.com/pika/pika/issues/824#issuecomment-309452627

we are using Pika blocking connection adapter, we do not have idle timeout set in our stack, but still its timing out at 180 sec max, here is the sample code, we tried to introduce heartbeat but that is not helping at all ... this is very critical and any help is greatly appreciated

params = pika.URLParameters(url)
params.socket_timeout = 300
params.heartbeat_interval = 20
params.blocked_connection_timeout = 300
connection = pika.BlockingConnection(params)
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body='Hello')
print "Sent 'Hello World!'"
print "sleeping "
time.sleep(280)

def callback(ch, method, properties, body):
print " Received %r" % (body)
channel.start_consuming()
channel.basic_consume(callback,
queue='hello',
no_ack=True)
connection.close()

[vitaly numenta]

There is more activity on the rabbitmq-users google group, including for pika, so your chances of getting pertinent help there are better. One of the first questions you will be asked is to describe your network topology, provide AMQP logs and pika debug-level logs demonstrating the issue.

[Gavin M. Roy]

You're blocking pika from being able to communicate for 280 seconds and being disconnected.  Don't do that and you should be fine.  See BlockingChannel.sleep

--
You received this message because you are subscribed to the Google Groups "Pika" group.
To unsubscribe from this group and stop receiving emails from it, send an email to pika-python+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[vitaly numenta]

Good point, thx Gavin