diff --git a/geonode/layers/models.py b/geonode/layers/models.py
index dbfe87ee734..7f0d92aa3aa 100644
--- a/geonode/layers/models.py
+++ b/geonode/layers/models.py
@@ -367,7 +367,7 @@ def view_count_up(self, user, do_local=False):
         if user == self.owner or user.is_superuser:
             return
         if not do_local:
-            from geonode.messaging import producer
+            from geonode.messaging.apps import producer
 
             producer.viewing_dataset(str(user), str(self.owner), self.id)
 
diff --git a/geonode/messaging/management/commands/runmessaging.py b/geonode/messaging/management/commands/runmessaging.py
index 5ab32e7d28e..b1010e6ac19 100644
--- a/geonode/messaging/management/commands/runmessaging.py
+++ b/geonode/messaging/management/commands/runmessaging.py
@@ -21,7 +21,7 @@
 
 from django.core.management.base import BaseCommand
 
-from geonode.messaging import connection
+from geonode.messaging.apps import connection
 from geonode.messaging.consumer import Consumer
 
 logger = logging.getLogger(__package__)
diff --git a/geonode/messaging/tests.py b/geonode/messaging/tests.py
index dc394636492..bd67c757bdb 100644
--- a/geonode/messaging/tests.py
+++ b/geonode/messaging/tests.py
@@ -19,7 +19,7 @@
 
 from geonode.tests.base import GeoNodeBaseTestSupport
 
-from geonode.messaging import connection
+from geonode.messaging.apps import connection
 from geonode.messaging.consumer import Consumer