Index: dialin/dg/fluid_leak.py
===================================================================
diff -u -ra34f654fb207c8bb35fcfcac155e4e5baa7f1d56 -r33e3f9f462c34f5ac8f8319dc3fada668b829190
--- dialin/dg/fluid_leak.py	(.../fluid_leak.py)	(revision a34f654fb207c8bb35fcfcac155e4e5baa7f1d56)
+++ dialin/dg/fluid_leak.py	(.../fluid_leak.py)	(revision 33e3f9f462c34f5ac8f8319dc3fada668b829190)
@@ -58,7 +58,7 @@
         """
         return self.fluid_leak_state
 
-    @_publish("fluid_leak_state")
+    @_publish(["fluid_leak_state"])
     def _handler_fluid_leak_sync(self, message):
         """
         Handles published fluid leak state messages.  Fluid leak state is captured
Index: dialin/hd/fluid_leak.py
===================================================================
diff -u -r2e392c92d55178f457a67423ba8c503a86dcf3c8 -r33e3f9f462c34f5ac8f8319dc3fada668b829190
--- dialin/hd/fluid_leak.py	(.../fluid_leak.py)	(revision 2e392c92d55178f457a67423ba8c503a86dcf3c8)
+++ dialin/hd/fluid_leak.py	(.../fluid_leak.py)	(revision 33e3f9f462c34f5ac8f8319dc3fada668b829190)
@@ -58,7 +58,7 @@
         """
         return self.fluid_leak_state
 
-    @_publish("fluid_leak_state")
+    @_publish(["fluid_leak_state"])
     def _handler_fluid_leak_sync(self, message):
         """
         Handles published fluid leak state messages.  Fluid leak state is captured
Index: tests/peter/test_hd_fluid_leak.py
===================================================================
diff -u
--- tests/peter/test_hd_fluid_leak.py	(revision 0)
+++ tests/peter/test_hd_fluid_leak.py	(revision 33e3f9f462c34f5ac8f8319dc3fada668b829190)
@@ -0,0 +1,47 @@
+###########################################################################
+#
+# Copyright (c) 2019-2020 Diality Inc. - All Rights Reserved.
+#
+# THIS CODE MAY NOT BE COPIED OR REPRODUCED IN ANY FORM, IN PART OR IN
+# WHOLE, WITHOUT THE EXPLICIT PERMISSION OF THE COPYRIGHT OWNER.
+#
+# @file test_alarms.py
+#
+# @author (last) Peter Lucia
+# @date (last) 03-May-2020
+# @author (original) Peter Lucia
+# @date (original) 03-May-2020
+#
+############################################################################
+import numpy as np
+import sys
+from time import sleep
+sys.path.append("..")
+from dialin import HDSimulator
+from dialin.protocols.CAN import DenaliMessage, DenaliChannels
+from dialin.common import MsgIds
+from dialin.utils.conversions import integer_to_bytearray, float_to_bytearray
+def run():
+    hd_sim = HDSimulator(log_level="DEBUG")
+    dg_sim = HDSimulator(log_level="DEBUG")
+
+    while True:
+        state = np.random.randint(0, 2)
+        payload = integer_to_bytearray(state)
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.hd_sync_broadcast_ch_id,
+                                              message_id=MsgIds.MSG_ID_DG_FLUID_LEAK_STATE.value,
+                                              payload=payload)
+
+        hd_sim.can_interface.send(message, 0)
+
+        message = DenaliMessage.build_message(channel_id=DenaliChannels.hd_sync_broadcast_ch_id,
+                                              message_id=MsgIds.MSG_ID_HD_FLUID_LEAK_STATE.value,
+                                              payload=payload)
+
+        dg_sim.can_interface.send(message, 0)
+        sleep(1)
+
+
+if __name__ == '__main__':
+    run()