Index: trunk/src/python/unifiedlogger/logging_service.py
===================================================================
--- trunk/src/python/unifiedlogger/logging_service.py	(revision 550)
+++ trunk/src/python/unifiedlogger/logging_service.py	(revision 649)
@@ -1,3 +1,3 @@
-import cms_watcher, cad_watcher, activitylog_watcher, time, json, ConfigParser
+import cms_watcher, har_watcher, cad_watcher, activitylog_watcher, time, json, ConfigParser
 # Unified Logging Service
 # jdalbey 7/6/2019
@@ -34,5 +34,5 @@
     f.close()            
     # List of the available plugin modules 
-    plugins = ["cms_watcher","cad_watcher","activitylog_watcher"]
+    plugins = ["cms_watcher","har_watcher","cad_watcher","activitylog_watcher"]
     #FOR each plugin LOOP
     for plugin in plugins:
Index: trunk/src/python/unifiedlogger/har_watcher.py
===================================================================
--- trunk/src/python/unifiedlogger/har_watcher.py	(revision 649)
+++ trunk/src/python/unifiedlogger/har_watcher.py	(revision 649)
@@ -0,0 +1,98 @@
+import json, time
+from copy import deepcopy
+
+# HAR Message Watcher
+# Look for changes in the HAR message file
+# jdalbey  2022.9.2
+idList = []    # list of CMS ID's
+prevList = []  # previous messages
+currList = []  # current messages
+locationMap = {} # map of HAR ID's to locations
+
+# Utility functions
+def isEmpty(cmsitem):
+     return cmsitem == ""
+def isFull(cmsitem):
+     return not isEmpty(cmsitem)
+
+# Read the har message file
+def readFile():     
+     with open ("webapps/dynamicdata/har_messages.json",'r') as myfile:
+          jsonData=myfile.read()
+ 
+     return json.loads(jsonData)['data']
+
+# Read the static file of cms locations and create a lookup map
+def loadLocations():
+     with open ("webapps/cptms/data_layers/har_locations_D12.gjson",'r') as myfile:
+          jsonData=myfile.read()
+ 
+     list = json.loads(jsonData)['features']
+     # add each item to a lookup map
+     for item in list:
+          locationMap [item['id']] = item['properties']['location'] + " " + item['properties']['street']
+     
+# Setup the ID list and initialize the previous messages to empty
+def initialize():
+     loadLocations()
+     msgList = readFile()
+     global prevList, idList
+     for idx in range(0,len(msgList)):
+          idList.append(msgList[idx]['har']['index'])
+          prevList.append("")
+     return msgList
+
+# Extract the current messages into a list
+def extractMessages(msgList):
+     global currList
+     currList = []
+     for idx in range(0,len(msgList)):
+          aMessage = msgList[idx]['har']['message']['phase1']['Line1']
+          currList.append(aMessage.replace("\n"," ").strip())
+
+def setup():
+     extractMessages(initialize())
+
+# compare previous messages to current messages to look for changes
+def getLogEntries():
+     global prevList, currList
+     msgList = readFile()
+     extractMessages(msgList)
+     size = len(currList)
+     
+     results = []
+     # Consider each HAR message
+     for idx in range(0,size):
+          # Is a new message activated?
+          if isEmpty(prevList[idx]) and isFull(currList[idx]):
+               results.append("HAR Activated," + idList[idx] + ", '" + currList[idx] +"'")
+          # Is an existing message turned off?
+          if isEmpty(currList[idx]) and isFull(prevList[idx]):
+               results.append("HAR Deactivated, " + idList[idx])
+          # Did a message change?
+          if isFull(currList[idx]) and isFull(prevList[idx]) and currList[idx] != prevList[idx]:
+               results.append("HAR Updated, " + idList[idx] + ", '" + currList[idx] +"'")
+
+     # Save the current list as previous
+     prevList = deepcopy(currList)
+     return results
+
+# Local main for unit testing
+def main():
+     global currList
+     setup()
+     # Loop Forever
+     while True:
+          # Look for changed messages
+          answer = getLogEntries()
+          # Output results
+          for item in answer:
+               print item
+          # wait 
+          time.sleep(5)
+          # Get the current messages
+          extractMessages(readFile())
+
+if __name__ == "__main__":
+     main()
+