diff options
Diffstat (limited to 'kombu/transport/pika2.py')
| -rw-r--r-- | kombu/transport/pika2.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/kombu/transport/pika2.py b/kombu/transport/pika2.py index bf1ab721..aa5ed029 100644 --- a/kombu/transport/pika2.py +++ b/kombu/transport/pika2.py @@ -67,8 +67,8 @@ class Channel(blocking.BlockingChannel, base.StdChannel): return None, method, method._properties, method._body def queue_purge(self, queue=None, nowait=False): - return super(Channel, self).queue_purge(queue=queue, - nowait=nowait).message_count + return super(Channel, self).\ + queue_purge(queue=queue, nowait=nowait).method.message_count def basic_publish(self, message, exchange, routing_key, mandatory=False, immediate=False): @@ -103,8 +103,7 @@ class Channel(blocking.BlockingChannel, base.StdChannel): properties = spec.BasicProperties(priority=priority, content_type=content_type, content_encoding=content_encoding, - headers=headers, - **properties) + headers=headers) return body, properties def message_to_python(self, raw_message): |