diff --git a/raspberry-dataserver/hevclient.py b/raspberry-dataserver/hevclient.py
index f16980f3ccf304b36bb0b2020f9189e263762843..04236e90aefd8ce133f073af2567ba86b1c2a1e7 100755
--- a/raspberry-dataserver/hevclient.py
+++ b/raspberry-dataserver/hevclient.py
@@ -50,15 +50,17 @@ class HEVClient(object):
                 if payload["type"] == "keepalive":
                     #Still alive
                     continue
-                elif payload["type"] == "DATA":
+                elif payload["type"] == "broadcast":
                     with self._lock:
-                        self._values = payload["DATA"]
+                        self._values = payload["sensors"]
                 elif payload["type"] == "READBACK":
-                    with self._lock:
-                        self._readback = payload["READBACK"]
+                    pass
+                    #with self._lock:
+                    #    self._readback = payload["READBACK"]
                 elif payload["type"] == "CYCLE":
-                    with self._lock:
-                        self._cycle = payload["CYCLE"]
+                    pass
+                    #with self._lock:
+                    #    self._cycle = payload["CYCLE"]
                 elif payload["type"] == "THRESHOLDS":
                     with self._lock:
                         self._thresholds = payload["THRESHOLDS"]
diff --git a/raspberry-dataserver/hevfromtxt.py b/raspberry-dataserver/hevfromtxt.py
index c9a56ba4593f78885f344691e9b69aead9e4d252..1f44bb3fa7ccf70e524b6e7564ca0199d6bc9600 100755
--- a/raspberry-dataserver/hevfromtxt.py
+++ b/raspberry-dataserver/hevfromtxt.py
@@ -38,11 +38,10 @@ class hevfromtxt():
         while True:
             # directly setting private member variables in this edge case
             payload = CommsCommon.DataFormat()
-            payload.version = payload._RPI_VERSION
-            payload.timestamp = time_offset + self._timestamp[self._pos]
-            payload.pressure_buffer = self._pressure[self._pos]
-            payload.pressure_inhale = self._volume[self._pos]
-            payload.temperature_buffer = self._flow[self._pos]
+            payload.timestamp = int(time_offset + self._timestamp[self._pos] * 1000)
+            payload.pressure_buffer = int(self._pressure[self._pos])
+            payload.pressure_inhale = int(self._volume[self._pos])
+            payload.temperature_buffer = int(abs(self._flow[self._pos]))
             self.payloadrecv = payload
 
             if self._pos + self._increment < self._length: