From 834aa5abfc5d95d7127a57c7d922f157a07f82f1 Mon Sep 17 00:00:00 2001
From: Piv <18462828+Piv200@users.noreply.github.com>
Date: Fri, 21 Feb 2020 21:09:25 +1030
Subject: [PATCH] Add example zmq stuff for testing.

---
 SlamController/zmq_pair_testing/pair.py | 28 +++++++++++++++++++++++++
 1 file changed, 28 insertions(+)
 create mode 100644 SlamController/zmq_pair_testing/pair.py

diff --git a/SlamController/zmq_pair_testing/pair.py b/SlamController/zmq_pair_testing/pair.py
new file mode 100644
index 0000000..510a2be
--- /dev/null
+++ b/SlamController/zmq_pair_testing/pair.py
@@ -0,0 +1,28 @@
+import zmq
+from threading import Thread
+import time
+
+context = zmq.Context.instance()
+
+def client(context):
+    print('in thread')
+    socket = context.socket(zmq.SUB)
+    print('created socket')
+    socket.connect('tcp://localhost:5050')
+    socket.subscribe(b'slam_map')
+    while True:
+        print(socket.recv())
+
+def server(context):
+    print('in thread')
+    socket = context.socket(zmq.PUB)
+    print('created socket')
+    socket.bind('tcp://*:5050')
+    while True:
+        socket.send_multipart([b'slam_map', b'Hi'])
+        time.sleep(1)
+
+# client_thread = Thread(target=client, args=[context])
+server_thread = Thread(target=server, args=[context])
+server_thread.start()
+# client_thread.start()
\ No newline at end of file