kombu
kombu copied to clipboard
celery
Messaging library for Python.
In method publish of Class Producer, it says "keyword mandatory: Currently not supported." Can Productor support "mandatory" to support "basic.return"?
When using Python 2.7.13, I'm getting the following: ``` body: (1016b) Traceback (most recent call last): File "/usr/local/lib/python2.7/site-packages/kombu/message.py", line 62, in _reraise_error reraise(*self.errors[0]) File "/usr/local/lib/python2.7/site-packages/kombu/message.py", line 49, in __init__ body...
[test1.py.gz](https://github.com/celery/kombu/files/2337712/test1.py.gz) In the attached example I set interval_max=6 in the call to Connection.autoretry() However should the connection fail the retry interval goes above 6: $ python ~/test1.py WARNING:root:on_error called, interval=0...
https://github.com/celery/py-amqp/pull/208
Hi! Test case: 1. Stop the RabbitMQ server 2. Execute the following script ```python def on_error(exc, interval): print('error') def on_reconnection(new_channel): print('reconnected') def execute_method(channel): print('execute method') if __name__ == '__main__': from...
I have profiled the `apply_async` method, and I've figured out that a lot of time is being spend on `_lookup` method in [exchange](https://github.com/celery/kombu/blob/master/kombu/transport/virtual/exchange.py#L70) module if redis is the backend for...
### PROBLEM The json encoding of a timezone aware datetime is not parseable by `datetime.fromisoformat()`. ### SOLUTION Please keep the canonical offset `+00:00` in the date instead of removing it...
`Kombu version = 4.4.0` When I call publish on a closed connection, it blocks forever; No exception, No error messages whatsoever. I tried to set a retry policy but The...
_Maybe I had to create this issue in [Celery](https://github.com/celery/celery) repo._ When I started celery worker with option [`--task-events`](http://docs.celeryproject.org/en/latest/reference/celery.bin.worker.html#cmdoption-celery-worker-e), I noticed that the events are not automatically deleted from the queue....
From what I'm seeing, a kombu consumer using amqp doesn't gracefully recover from an issue such as a rabbitmq restart, or any recoverable error without explicitly calling `consumer.consume()` before any...
