diff --git a/roles/notifs/backend/files/monitoring.py b/roles/notifs/backend/files/monitoring.py
new file mode 100644
index 0000000000..26fb12bc64
--- /dev/null
+++ b/roles/notifs/backend/files/monitoring.py
@@ -0,0 +1,95 @@
+# This file is part of Moksha.
+# Copyright (C) 2014  Red Hat, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+# Authors: Ralph Bean  <rbean@redhat.com>
+
+from moksha.hub.api import PollingProducer
+import os
+import string
+import zmq
+import json
+
+import logging
+log = logging.getLogger(__name__)
+
+
+class MonitoringProducer(PollingProducer):
+    frequency = 5
+
+    ctx = None
+    socket = None
+
+    def __init__(self, hub, *args, **kwargs):
+
+        key = 'moksha.monitoring.socket'
+        endpoint = hub.config.get(key)
+        if not endpoint:
+            log.info("No %r defined.  Monitoring disabled." % key)
+            return
+
+        log.info("Establishing monitor sock at %r" % endpoint)
+
+        # Set up a special socket for ourselves
+        self.ctx = zmq.Context()
+        self.socket = self.ctx.socket(zmq.PUB)
+        self.socket.bind(endpoint)
+
+        # If this is a unix socket (which is almost always is) then set some
+        # permissions so that whatever monitoring service is deployed can talk
+        # to us.
+        mode = hub.config.get('moksha.monitoring.socket.mode')
+        if endpoint.startswith("ipc://") and mode:
+            mode = int(mode, base=8)
+            path = endpoint.split("ipc://")[-1]
+            os.chmod(path, mode)
+
+        super(MonitoringProducer, self).__init__(hub, *args, **kwargs)
+
+    def serialize(self, obj):
+        if isinstance(obj, list):
+            return [self.serialize(item) for item in obj]
+        elif isinstance(obj, dict):
+            return dict([(k, self.serialize(v)) for k, v in obj.items()])
+        elif hasattr(obj, '__json__'):
+            return obj.__json__()
+        return obj
+
+    def poll(self):
+        data = {
+            "consumers": self.serialize(self.hub.consumers),
+            "producers": self.serialize(self.hub.producers),
+        }
+        # Decode topics if they are byte array
+        # This will prevent the json.dumps() to fail
+        for consumer in data["consumers"]:
+            decoded_topics = []
+            for topic in consumer["topic"]:
+                if isinstance(topic, bytes):
+                    decoded_topics.append(topic.decode())
+            if decoded_topics:
+                consumer["topic"] = decoded_topics
+
+        if self.socket:
+            self.socket.send_string(json.dumps(data))
+
+    def stop(self):
+        super(MonitoringProducer, self).stop()
+        if self.socket:
+            self.socket.close()
+            self.socket = None
+
+        if self.ctx:
+            self.ctx.term()
+            self.ctx = None
diff --git a/roles/notifs/backend/tasks/main.yml b/roles/notifs/backend/tasks/main.yml
index 0aeeef2d2e..f338ce47ff 100644
--- a/roles/notifs/backend/tasks/main.yml
+++ b/roles/notifs/backend/tasks/main.yml
@@ -59,6 +59,16 @@
     #  when:
     #inventory_hostname.startswith('notifs-backend02') or env == 'staging'
 
+- name: hotfix python3-moksha-hub monitoring
+  copy: >
+    src=monitoring.py dest=/usr/lib/python3.10/site-packages/moksha/hub/monitoring.py
+    owner=root group=root mode=0644
+  notify:
+  - restart fedmsg-hub
+  tags:
+  - notifs
+  - notifs/backend
+
 - name: hotfix python3-moksha-hub
   copy: >
     src=consumer.py dest=/usr/lib/python3.10/site-packages/moksha/hub/api/consumer.py