Index: leahi_dialin/dd/dialysate_delivery.py
===================================================================
diff -u -rba2793fd2b970fc89af085f1dfe4e8b6fe408353 -r63d26c9e41e02f8a4c0ad59dab9cc6575e501357
--- leahi_dialin/dd/dialysate_delivery.py	(.../dialysate_delivery.py)	(revision ba2793fd2b970fc89af085f1dfe4e8b6fe408353)
+++ leahi_dialin/dd/dialysate_delivery.py	(.../dialysate_delivery.py)	(revision 63d26c9e41e02f8a4c0ad59dab9cc6575e501357)
@@ -85,16 +85,18 @@
         # register handler for DD operation mode broadcast messages
         if self.can_interface is not None:
             channel_id = DenaliChannels.dd_sync_broadcast_ch_id
-            msg_id = MsgIds.MSG_ID_DD_OP_MODE_DATA.value
-            self.can_interface.register_receiving_publication_function(channel_id, msg_id,
+            self.msg_id_dd_op_mode_data = MsgIds.MSG_ID_DD_OP_MODE_DATA.value
+            self.can_interface.register_receiving_publication_function(channel_id, self.msg_id_dd_op_mode_data,
                                                                        self._handler_dd_op_mode_sync)
 
+            self.msg_id_dd_version_response = MsgIds.MSG_ID_DD_VERSION_RESPONSE.value
             self.can_interface.register_receiving_publication_function(channel_id,
-                                                                       MsgIds.MSG_ID_DD_VERSION_RESPONSE.value,
+                                                                       self.msg_id_dd_version_response,
                                                                        self._handler_dd_version_response_sync)
 
+            self.msg_id_dd_debug_event = MsgIds.MSG_ID_DD_DEBUG_EVENT.value
             self.can_interface.register_receiving_publication_function(channel_id,
-                                                                       MsgIds.MSG_ID_DD_DEBUG_EVENT.value,
+                                                                       self.msg_id_dd_debug_event,
                                                                        self._handler_dd_debug_event_sync)
 
         # create properties
@@ -135,7 +137,7 @@
         self.td_proxy = TDProxy(self.can_interface, self.logger)
 
 
-    @publish(["dd_debug_events_timestamp","dd_debug_events"])
+    @publish(["msg_id_dd_debug_event", "dd_debug_events_timestamp","dd_debug_events"])
     def _handler_dd_debug_event_sync(self, message, timestamp = 0.0):
 
         payload = message['message']
@@ -166,7 +168,7 @@
         """
         self.dd_logged_in = logged_in
 
-    @publish(["dd_op_mode_timestamp","dd_operation_mode", "dd_operation_sub_mode"])
+    @publish(["msg_id_dd_op_mode_data", "dd_op_mode_timestamp","dd_operation_mode", "dd_operation_sub_mode"])
     def _handler_dd_op_mode_sync(self, message, timestamp = 0.0):
         """
         Handles published DD operation mode messages.  Current DD operation mode
@@ -184,7 +186,7 @@
         self.dd_operation_sub_mode = smode[0]
         self.dd_op_mode_timestamp = timestamp
 
-    @publish(["dd_version, dd_fpga_version"])
+    @publish(["msg_id_dd_version_response", "dd_version, dd_fpga_version"])
     def _handler_dd_version_response_sync(self,message, timestamp = 0.0):
         """
         Handler for response from DD regarding its version.