diff options
Diffstat (limited to 'kombu/tests/mocks.py')
| -rw-r--r-- | kombu/tests/mocks.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/kombu/tests/mocks.py b/kombu/tests/mocks.py index 836457eb..5af53b19 100644 --- a/kombu/tests/mocks.py +++ b/kombu/tests/mocks.py @@ -2,9 +2,8 @@ from __future__ import absolute_import from itertools import count -import anyjson - from kombu.transport import base +from kombu.utils import json class Message(base.Message): @@ -104,7 +103,7 @@ class Channel(base.StdChannel): def message_to_python(self, message, *args, **kwargs): self._called('message_to_python') - return Message(self, body=anyjson.dumps(message), + return Message(self, body=json.dumps(message), delivery_tag=next(self.deliveries), throw_decode_error=self.throw_decode_error, content_type='application/json', |