Get channel properly in RPC Caller. It's a function, moron.

This commit is contained in:
Nick Hurley 2013-01-31 14:29:29 -08:00
Родитель 2831df0b9e
Коммит 0f20475d66
1 изменённых файлов: 1 добавлений и 1 удалений

Просмотреть файл

@ -564,7 +564,7 @@ class RpcCaller(object):
params = pika.ConnectionParameters(host=self._host)
self._connection = pika.BlockingConnection(params)
self._channel = self._connection.channel
self._channel = self._connection.channel()
self._channel.basic_consume(self._on_rpc_done, no_ack=True,
queue=self._incoming_queue)