carrot
carrot copied to clipboard
ask
AMQP Messaging Framework for Python (discontinued; Use Kombu instead)
There are small typos in: - carrot/backends/librabbitmq.py - carrot/backends/pyamqplib.py - carrot/backends/pystomp.py - carrot/messaging.py - carrot/utils.py Fixes: - Should read `instantiate` rather than `insantiate`. - Should read `overflowing` rather than `oveflowing`....
when try the example got error consumer.py ``` from carrot.messaging import Consumer from carrot.connection import BrokerConnection conn = BrokerConnection(hostname="localhost", port=5672, userid="test", password="test", virtual_host="test") consumer = Consumer(connection=conn, queue="feed",exchange="feed", routing_key="importer") def import_feed_callback(message_data,...
Line 1 of carrot/utils.py imports _uuid_generate_random which no longer exists in python 2.7.11. I am running python 2.7.11 on Windows 10 currently. Possible code to fix. try: from uuid import...
When I try to do this straight from the introduction: from carrot.connection import AMQPConnection amqpconn = AMQPConnection(hostname="localhost", port=5672, userid="test", password="test", vhost="test") the whole thing ends up in a busy loop:...
Apache Qpid supports the latest version of AMQP 0-10 while py-amqplib only supports AMQP 0-8. I suggest that AMQP client library should be like a plugin for one to be...
I'm still trying to find a way to get rid of the ghettoq DB backend and I tried the memory which sounds very close to what I'm looking for. But......
Without having intricate (or cursory) knowledge of sockets, it seems to me that only a very basic failure scenario is handled by the `connect_timeout` (perhaps aptly named to indicate that...
The documentation for the mandatory parameter of publisher.send states: "If set, the message has mandatory routing. By default the message is silently dropped by the server if it can’t be...
When declaring a "Consumer", the exchange is also declared. This means the consumers `auto_delete` setting will be used for the exchange as well. I see some solutions here: 1) Don't...
# Running the tests results in: ``` FAIL: test_consumerset_iterconsume (tests.test_pyamqplib.TestAMQPlibMessaging) ---------------------------------------------------------------------- Traceback (most recent call last): File "/tmp/buildd/python-carrot-0.10.5/tests/backend.py", line 465, in test_consumerset_iterconsume assertDataIs({"rkey": "foo.baz"}) File "/tmp/buildd/python-carrot-0.10.5/tests/backend.py", line 446, in assertDataIs...
