amqp - Celery not connecting to Redis broker: Connection to broker lost -


i'm trying redis work broker celery 3.0.19 install on django. see redis-server running on port 6379. when run simple celery test, following stack trace:

ubuntu lucid 10.0.4 celery 3.0.19  celery -a tasks worker --loglevel=info  [2013-05-02 18:56:27,835: info/mainprocess] consumer: connected redis://127.0.0.1:6379/0. [2013-05-02 18:56:27,835: error/mainprocess] consumer: connection broker lost. trying re-establish connection... traceback (most recent call last): file "/usr/local/lib/python2.6/dist-packages/celery/worker/consumer.py", line 394, in start self.reset_connection() file "/usr/local/lib/python2.6/dist-packages/celery/worker/consumer.py", line 744, in reset_connection self.connection, on_decode_error=self.on_decode_error, file "/usr/local/lib/python2.6/dist-packages/celery/app/amqp.py", line 311, in __init__ **kw file "/usr/local/lib/python2.6/dist-packages/kombu/messaging.py", line 355, in __init__ self.revive(self.channel) file "/usr/local/lib/python2.6/dist-packages/kombu/messaging.py", line 367, in revive self.declare() file "/usr/local/lib/python2.6/dist-packages/kombu/messaging.py", line 377, in declare queue.declare() file "/usr/local/lib/python2.6/dist-packages/kombu/entity.py", line 490, in declare self.queue_declare(nowait, passive=false) file "/usr/local/lib/python2.6/dist-packages/kombu/entity.py", line 516, in queue_declare nowait=nowait) file "/usr/local/lib/python2.6/dist-packages/kombu/transport/virtual/__init__.py", line 404, in queue_declare return queue, self._size(queue), 0 file "/usr/local/lib/python2.6/dist-packages/kombu/transport/redis.py", line 516, in _size sizes = cmds.execute() file "/usr/local/lib/python2.6/dist-packages/redis/client.py", line 1919, in execute return execute(conn, stack, raise_on_error) file "/usr/local/lib/python2.6/dist-packages/redis/client.py", line 1811, in _execute_transaction self.parse_response(connection, '_') file "/usr/local/lib/python2.6/dist-packages/redis/client.py", line 1882, in parse_response self, connection, command_name, **options) file "/usr/local/lib/python2.6/dist-packages/redis/client.py", line 387, in parse_response response = connection.read_response() file "/usr/local/lib/python2.6/dist-packages/redis/connection.py", line 312, in read_response raise response responseerror: unknown command 'multi' 

you need redis version >= 2.2.0.


Comments

Popular posts from this blog

linux - Does gcc have any options to add version info in ELF binary file? -

android - send complex objects as post php java -

charts - What graph/dashboard product is facebook using in Dashboard: PUE & WUE -