Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Bumped version to 0.9.2

This commit is contained in:
Ask Solem 2010-11-10 09:35:05 +01:00
parent bf79a76b34
commit 1329a15fb5
3 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.rst
View File

@ -2,7 +2,7 @@
kombu - AMQP Messaging Framework for Python kombu - AMQP Messaging Framework for Python
############################################# #############################################
:Version: 0.9.1 :Version: 0.9.2
**THIS IS A REWRITE OF CARROT** **THIS IS A REWRITE OF CARROT**

2
kombu/__init__.py
View File

@ -1,5 +1,5 @@
"""AMQP Messaging Framework for Python""" """AMQP Messaging Framework for Python"""
VERSION = (0, 9, 1) VERSION = (0, 9, 2)
__version__ = ".".join(map(str, VERSION)) __version__ = ".".join(map(str, VERSION))
__author__ = "Ask Solem" __author__ = "Ask Solem"
__contact__ = "ask@celeryproject.org" __contact__ = "ask@celeryproject.org"

20
kombu/transport/pypika.py
View File

@ -50,18 +50,23 @@ class Channel(channel.Channel):
def basic_publish(self, message, exchange, routing_key, mandatory=False, def basic_publish(self, message, exchange, routing_key, mandatory=False,
immediate=False): immediate=False):
message_data, properties = message message_data, properties = message
return channel.Channel.basic_publish(self, try:
exchange, return channel.Channel.basic_publish(self,
routing_key, exchange,
message_data, routing_key,
properties, message_data,
mandatory, properties,
immediate) mandatory,
immediate)
finally:
self.handler.connection.flush_outbound()
def basic_consume(self, queue, no_ack=False, consumer_tag=None, def basic_consume(self, queue, no_ack=False, consumer_tag=None,
callback=None, nowait=False): callback=None, nowait=False):
def _callback_decode(channel, method, header, body): def _callback_decode(channel, method, header, body):
print("IN CALLBACK DECODE: %r" % (
channel, method, header, body))
return callback((channel, method, header, body)) return callback((channel, method, header, body))
return channel.Channel.basic_consume(self, _callback_decode, return channel.Channel.basic_consume(self, _callback_decode,
@ -81,6 +86,7 @@ class Channel(channel.Channel):
def message_to_python(self, raw_message): def message_to_python(self, raw_message):
"""Convert encoded message body back to a Python value.""" """Convert encoded message body back to a Python value."""
print("RAW MESSAGE: %r" % (raw_message, ))
return self.Message(channel=self, amqp_message=raw_message) return self.Message(channel=self, amqp_message=raw_message)
def basic_ack(self, delivery_tag): def basic_ack(self, delivery_tag):