From 1329a15fb5e1333967b317183595588418cea129 Mon Sep 17 00:00:00 2001
From: Ask Solem <askh@opera.com>
Date: Wed, 10 Nov 2010 09:35:05 +0100
Subject: [PATCH] Bumped version to 0.9.2

---
 README.rst                |  2 +-
 kombu/__init__.py         |  2 +-
 kombu/transport/pypika.py | 20 +++++++++++++-------
 3 files changed, 15 insertions(+), 9 deletions(-)

diff --git a/README.rst b/README.rst
index 46ad74d6..2250ec2c 100644
--- a/README.rst
+++ b/README.rst
@@ -2,7 +2,7 @@
  kombu - AMQP Messaging Framework for Python
 #############################################
 
-:Version: 0.9.1
+:Version: 0.9.2
 
 **THIS IS A REWRITE OF CARROT**
 
diff --git a/kombu/__init__.py b/kombu/__init__.py
index f0e49d63..08315216 100644
--- a/kombu/__init__.py
+++ b/kombu/__init__.py
@@ -1,5 +1,5 @@
 """AMQP Messaging Framework for Python"""
-VERSION = (0, 9, 1)
+VERSION = (0, 9, 2)
 __version__ = ".".join(map(str, VERSION))
 __author__ = "Ask Solem"
 __contact__ = "ask@celeryproject.org"
diff --git a/kombu/transport/pypika.py b/kombu/transport/pypika.py
index 1fc7d9c7..0f3c3791 100644
--- a/kombu/transport/pypika.py
+++ b/kombu/transport/pypika.py
@@ -50,18 +50,23 @@ class Channel(channel.Channel):
     def basic_publish(self, message, exchange, routing_key, mandatory=False,
             immediate=False):
         message_data, properties = message
-        return channel.Channel.basic_publish(self,
-                                            exchange,
-                                            routing_key,
-                                            message_data,
-                                            properties,
-                                            mandatory,
-                                            immediate)
+        try:
+            return channel.Channel.basic_publish(self,
+                                                 exchange,
+                                                 routing_key,
+                                                 message_data,
+                                                 properties,
+                                                 mandatory,
+                                                 immediate)
+        finally:
+            self.handler.connection.flush_outbound()
 
     def basic_consume(self, queue, no_ack=False, consumer_tag=None,
             callback=None, nowait=False):
 
         def _callback_decode(channel, method, header, body):
+            print("IN CALLBACK DECODE: %r" % (
+                channel, method, header, body))
             return callback((channel, method, header, body))
 
         return channel.Channel.basic_consume(self, _callback_decode,
@@ -81,6 +86,7 @@ class Channel(channel.Channel):
 
     def message_to_python(self, raw_message):
         """Convert encoded message body back to a Python value."""
+        print("RAW MESSAGE: %r" % (raw_message, ))
         return self.Message(channel=self, amqp_message=raw_message)
 
     def basic_ack(self, delivery_tag):