Updates Changelog

Changelog

@@ -8,6 +8,46 @@
 =====
 :release-date: 2012-06-12 7:07 P.M BST
 
+- SQS: Default visibility timeout is now 30 minutes.
+
+    Since we have ack emulation the visibility timeout is
+    only in effect if the consumer is abrubtly terminated.
+
+- retry argument to ``Producer.publish`` now works properly,
+  when the declare argument is specified.
+
+- Json serializer: didn't handle buffer objects (Issue #135).
+
+    Fix contributed by Jens Hoffrichter.
+
+- Virtual: Now supports passive argument to ``exchange_declare``.
+
+- Exchange & Queue can now be bound to connections (which will use the default
+  channel):
+
+    >>> exchange = Exchange("name")
+    >>> bound_exchange = exchange(connection)
+    >>> bound_exchange.declare()
+
+- SimpleQueue & SimpleBuffer can now be bound to connections (which will use
+  the default channel).
+
+- Connection.manager.get_bindings now works for librabbitmq and pika.
+
+- Adds new transport info attributes::
+
+    - ``Transport.driver_type``
+
+        Type of underlying driver, e.g. "amqp", "redis", "sql".
+
+    - ``Transport.driver_name``
+
+        Name of library used e.g. "amqplib", "redis", "pymongo".
+
+    - ``Transport.driver_version()``
+
+        Version of underlying library.
+
 .. _version-2.2.0:
 
 2.2.0

README.rst

@@ -197,15 +197,17 @@ just remember to close the objects after use::
 and used in configuration files etc.
 
 They also support operations, but to do so they need to be bound
-to a channel:
+to a channel.
+
+Binding exchanges and queues to a connection will make it use
+that connections default channel.
 
 ::
 
     >>> exchange = Exchange("tasks", "direct")
 
     >>> connection = BrokerConnection()
-    >>> channel = connection.channel()
-    >>> bound_exchange = exchange(channel)
+    >>> bound_exchange = exchange(connection)
     >>> bound_exchange.delete()
 
     # the original exchange is not affected, and stays unbound.

kombu/serialization.py

@@ -56,14 +56,16 @@ def _decode(t, coding):
 
 # cPickle.loads does not support buffer() objects,
 # but we can just create a StringIO and use load.
-if sys.version_info[0] == 2:
+if sys.version_info[0] == 3:
+    from io import StringIO
+else:
     try:
-        from cStringIO import StringIO
+        from cStringIO import StringIO  # noqa
     except ImportError:
-        from StringIO import StringIO  # noqa
+        from StringIO import StringIO   # noqa
 
-    def pickle_loads(s, load=pickle_load):
-        return load(StringIO(s))
+def pickle_loads(s, load=pickle_load):
+    return load(StringIO(s))
 
 
 class SerializerRegistry(object):