Index: leahi_dialin/dd/modules/levels.py
===================================================================
diff -u -rfd7a25d8f068bcba594c01410a02a03f6afbcd59 -r6edd833759b929135e2a39f00eff1f814796329d
--- leahi_dialin/dd/modules/levels.py	(.../levels.py)	(revision fd7a25d8f068bcba594c01410a02a03f6afbcd59)
+++ leahi_dialin/dd/modules/levels.py	(.../levels.py)	(revision 6edd833759b929135e2a39f00eff1f814796329d)
@@ -54,7 +54,10 @@
             self.can_interface.register_receiving_publication_function(channel_id, msg_id, self._handler_heaters_sync)
 
     @publish(["dd_levels_timestamp",
-                "",])
+                "floater1",
+              "floater2",
+              "bicarb_level",
+              "spent_dialysate_level"])
     def _handler_heaters_sync(self, message, timestamp=0.0):
         """
         Handles published heaters message
@@ -68,7 +71,7 @@
             message['message'][MsgFieldPositions.START_POS_FIELD_2:MsgFieldPositions.END_POS_FIELD_2]))[0]
         self.bicarb_level = struct.unpack('i', bytearray(
             message['message'][MsgFieldPositions.START_POS_FIELD_3:MsgFieldPositions.END_POS_FIELD_3]))[0]
-        self.dd_levels_timestamp = struct.unpack('i', bytearray(
+        self.spent_dialysate_level = struct.unpack('i', bytearray(
             message['message'][MsgFieldPositions.START_POS_FIELD_4:MsgFieldPositions.END_POS_FIELD_4]))[0]
 
         self.dd_levels_timestamp = timestamp
@@ -119,15 +122,13 @@
         @returns 1 if successful, zero otherwise
         """
         reset_value = integer_to_bytearray(reset)
-        level_sensor = integer_to_bytearray(heater)
+        level_sensor = integer_to_bytearray(level_sensor)
         sts = integer_to_bytearray(status)
         payload = reset_value + sts + level_sensor
         message = DenaliMessage.build_message(channel_id=DenaliChannels.dialin_to_dd_ch_id,
                                               message_id=MsgIds.MSG_ID_DD_LEVELS_STATUS_OVERRIDE_REQUEST.value,
                                               payload=payload)
 
-        self.logger.debug("Overriding {} heater's duty cycle to {:5.3f} %".format(HeatersNames(heater).name, duty_cycle))
-        # Send message
         received_message = self.can_interface.send(message)
 
         # If there is content in message