diff --git a/awx/main/utils/formatters.py b/awx/main/utils/formatters.py
index 68d0917985..4990047829 100644
--- a/awx/main/utils/formatters.py
+++ b/awx/main/utils/formatters.py
@@ -14,6 +14,7 @@ class LogstashFormatter(LogstashFormatterVersion1):
         if settings_module:
             self.host_id = settings_module.CLUSTER_HOST_ID
             self.tower_uuid = settings_module.LOG_AGGREGATOR_TOWER_UUID
+            self.message_type = settings_module.LOG_AGGREGATOR_TYPE
         return ret
 
     def reformat_data_for_log(self, raw_data, kind=None):