diff --git a/cluster.py b/cluster.py
new file mode 100644
index 0000000..f47c15a
--- /dev/null
+++ b/cluster.py
@@ -0,0 +1,25 @@
+import paho.mqtt.subscribe as mqtt
+import json
+
+BROKER = ('homeproxy', 1883)
+TOPIC_RAW = 'scalefix/raw/weight'
+TOPIC_USERS = 'scalefix/users'
+
+
+_users={}
+
+def handle_weight(client, userdata, message):
+    pass
+
+def handle_user(client, userdata, message):
+    pass
+
+
+TOPIC_LAST = TOPIC_USERS+'/last'
+def dispatch(client, userdata, message):
+    if message.topic == TOPIC_RAW:
+        handle_weight(client, userdata, message)
+    elif message.topic.startswith(TOPIC_LAST):
+        handle_user(client, userdata, message)
+
+mq.callback(dispatch, [TOPIC_RAW, TOPIC_LAST+'/+'], hostname=BROKER[0], port=BROKER[1])