py-amqp
py-amqp copied to clipboard
celery
amqplib fork
I was testing utilizing this package on a Windows 7 Enterprise N, 64-bit machine and ran into the error listed below. The problem seems to be with attempting to set...
While long-running message handlers (amqp_method) run, inbound frames need to continue to be processed in the background so that heartbeat frames (frame_type == 8) can continue to increment the bytes_recd...
I'm using Celery for messaging and recently noticed that my `task.delay` requests were blocking forever. I traced out the code from celery, into kombu, and eventually in py-amqp. I eventually...
How is possible to bind a callback function in order to detect the disconnection ? In pika for example there is a useful binding. This should be present in order...
See https://docs.python.org/3/library/socket.html#socket.socket.settimeout. This commit was triggered by https://github.com/celery/celery/issues/4876#issuecomment-502922066. It could fix the issue as well.
On Python 2 the following dictionary: ```python {'': '\x80'} ``` is deserialized as: ```python {'': '\xc2\x80'} ``` That's incorrect and we should find a way to fix it. The problem...
Based on https://github.com/pika/pika/commit/3027890081adaa067268aa4839638a32734c263f and ``` Heartbeat Timeout Value The heartbeat timeout value defines after what period of time the peer TCP connection should be considered unreachable (down) by RabbitMQ and...
`Channel.basic_consume()` now has 2 return values: * consumer_tag - when `nowait == False` * promise object wen `nowait == True` * `ValueError()` when `nowait == True` and user does not...
is it possible to talk to qpid-cpp-broker using this library? Problem details available at https://stackoverflow.com/questions/51642901/does-py-amqp-support-amqp-0-10
https://github.com/djsmith42/py-amqp/commit/3bc856f3276265ebf265327a7f31bbc3c3caf75d
