1 files changed, 25 insertions, 0 deletions
diff --git a/contrib/zmq_recv.go b/contrib/zmq_recv.go
new file mode 100644
index 0000000..cd47fec
--- /dev/null
+++ b/contrib/zmq_recv.go
@@ -0,0 +1,25 @@
+package main
+
+import (
+    "fmt";
+    "strings";
+    zmq "github.com/pebbe/zmq4"
+)
+
+func main() {
+    subscriber, _ := zmq.NewSocket(zmq.SUB)
+    defer subscriber.Close()
+    subscriber.Connect("tcp://localhost:6666")
+
+    subscriber.SetSubscribe("")
+
+    for {
+        msg, _ := subscriber.RecvMessage(0)
+        if (strings.HasPrefix(msg[0], "event.v1")) {
+            fmt.Println("Got event message.. %d", len(msg), msg)
+        } else if (strings.HasPrefix(msg[0], "data.v1")) {
+            fmt.Println("Got data message.. %d", len(msg), msg)
+        }
+    }
+
+}