diff options
author | Ask Solem <ask@celeryproject.org> | 2012-01-15 18:34:47 +0000 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2012-01-15 18:35:21 +0000 |
commit | 8507bd8dffc8ff42c8b456a2d3b7b0f5d63cbb65 (patch) | |
tree | fa38e776578df3ac3b3f1a4ae3ade4b67c66a459 /kombu/transport/SQS.py | |
parent | 2a0bfebdf703839f29068fb9638f580f2619369d (diff) | |
download | kombu-8507bd8dffc8ff42c8b456a2d3b7b0f5d63cbb65.tar.gz |
Cosmetics
Diffstat (limited to 'kombu/transport/SQS.py')
-rw-r--r-- | kombu/transport/SQS.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kombu/transport/SQS.py b/kombu/transport/SQS.py index fd3fc2fb..4ec202ef 100644 --- a/kombu/transport/SQS.py +++ b/kombu/transport/SQS.py @@ -15,7 +15,7 @@ import string from Queue import Empty -from anyjson import serialize, deserialize +from anyjson import loads, dumps from boto import exception from boto import sdb as _sdb @@ -214,7 +214,7 @@ class Channel(virtual.Channel): """Put message onto queue.""" q = self._new_queue(queue) m = Message() - m.set_body(serialize(message)) + m.set_body(dumps(message)) q.write(m) def _put_fanout(self, exchange, message, **kwargs): @@ -228,7 +228,7 @@ class Channel(virtual.Channel): rs = q.get_messages(1) if rs: m = rs[0] - payload = deserialize(rs[0].get_body()) + payload = loads(rs[0].get_body()) if queue in self._noack_queues: q.delete_message(m) else: |