diff --git a/python_apps/pypo/pypofetch.py b/python_apps/pypo/pypofetch.py
index 860ed781e..4328260a5 100644
--- a/python_apps/pypo/pypofetch.py
+++ b/python_apps/pypo/pypofetch.py
@@ -53,7 +53,7 @@ class PypoFetch(Thread):
     def handle_message(self, message):
         try:        
             logger = logging.getLogger('fetch')
-            logger.info("Received event from RabbitMQ: %s" % message)
+            logger.info("Received event from Pypo Message Handler: %s" % message)
             
             m =  json.loads(message)
             command = m['event_type']
@@ -79,7 +79,7 @@ class PypoFetch(Thread):
             top = traceback.format_exc()
             logger.error('Exception: %s', e)
             logger.error("traceback: %s", top)
-            logger.error("Exception in handling RabbitMQ message: %s", e)
+            logger.error("Exception in handling Message Handler message: %s", e)
         
     def stop_current_show(self):
         logger = logging.getLogger('fetch')
diff --git a/python_apps/pypo/recorder.py b/python_apps/pypo/recorder.py
index a4052c485..cd57617d9 100644
--- a/python_apps/pypo/recorder.py
+++ b/python_apps/pypo/recorder.py
@@ -183,7 +183,7 @@ class Recorder(Thread):
             message = self.queue.get()
             msg =  json.loads(message)
             command = msg["event_type"]
-            self.logger.info("Received msg from Pypo Fetch: %s", msg)
+            self.logger.info("Received msg from Pypo Message Handler: %s", msg)
             if command == 'cancel_recording':
                 if self.sr is not None and self.sr.is_recording():
                     self.sr.cancel_recording()