Cosmetics

1 files changed, 3 insertions, 3 deletions

diff --git a/kombu/transport/sqlalchemy/__init__.py b/kombu/transport/sqlalchemy/__init__.py
index 6c8e73e5..8f7c25a2 100644
--- a/kombu/transport/sqlalchemy/__init__.py
+++ b/kombu/transport/sqlalchemy/__init__.py
@@ -2,7 +2,7 @@
 
 from Queue import Empty
 
-from anyjson import serialize, deserialize
+from anyjson import loads, dumps
 from sqlalchemy import create_engine
 from sqlalchemy.exc import OperationalError
 from sqlalchemy.orm import sessionmaker
@@ -59,7 +59,7 @@ class Channel(virtual.Channel):
 
     def _put(self, queue, payload, **kwargs):
         obj = self._get_or_create(queue)
-        message = Message(serialize(payload), obj)
+        message = Message(dumps(payload), obj)
         self.session.add(message)
         try:
             self.session.commit()
@@ -81,7 +81,7 @@ class Channel(virtual.Channel):
                         .first()
             if msg:
                 msg.visible = False
-                return deserialize(msg.payload)
+                return loads(msg.payload)
             raise Empty()
         finally:
             self.session.commit()