diff --git a/examples/pub_sub.go b/examples/pub_sub.go
new file mode 100644
index 00000000..8cc6a51e
--- /dev/null
+++ b/examples/pub_sub.go
@@ -0,0 +1,42 @@
+package main
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/asim/go-micro/broker"
+)
+
+var (
+	topic = "go.micro.topic.foo"
+)
+
+func pub() {
+	tick := time.NewTicker(time.Second)
+	i := 0
+	for _ = range tick.C {
+		msg := fmt.Sprintf("%d: %s", i, time.Now().String())
+		fmt.Println("[pub] pubbed message:", msg)
+		broker.Publish(topic, []byte(msg))
+		i++
+	}
+}
+
+func sub() {
+	_, err := broker.Subscribe(topic, func(msg *broker.Message) {
+		fmt.Println("[sub] received message:", string(msg.Data))
+	})
+	if err != nil {
+		fmt.Println(err)
+	}
+}
+
+func main() {
+	broker.Init()
+	broker.Connect()
+
+	go pub()
+	go sub()
+
+	<-time.After(time.Second * 10)
+}