1 files changed, 2 insertions, 3 deletions
diff --git a/kombu/transport/django/__init__.py b/kombu/transport/django/__init__.py
index 67bfa576..9dde51a2 100644
--- a/kombu/transport/django/__init__.py
+++ b/kombu/transport/django/__init__.py
@@ -1,14 +1,14 @@
 """Kombu transport using the Django database as a message store."""
 from __future__ import absolute_import
 
-from anyjson import loads, dumps
-
 from django.conf import settings
 from django.core import exceptions as errors
 
 from kombu.five import Empty
 from kombu.transport import virtual
 from kombu.utils.encoding import bytes_to_str
+from kombu.utils.json import loads, dumps
+
 
 from .models import Queue
 
@@ -35,7 +35,6 @@ class Channel(virtual.Channel):
         super(Channel, self).basic_consume(queue, *args, **kwargs)
 
     def _get(self, queue):
-        #self.refresh_connection()
         m = Queue.objects.fetch(queue)
         if m:
             return loads(bytes_to_str(m))