From 018183fa49e7334f5257ea1af4717ecac9f4a97e Mon Sep 17 00:00:00 2001
From: Asim <asim@chuhnk.me>
Date: Sat, 23 May 2015 17:55:08 +0100
Subject: [PATCH] bail if you cant connect

---
 examples/pub_sub.go | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/examples/pub_sub.go b/examples/pub_sub.go
index 5013679e..6b22ac73 100644
--- a/examples/pub_sub.go
+++ b/examples/pub_sub.go
@@ -4,7 +4,9 @@ import (
 	"fmt"
 	"time"
 
+	log "github.com/golang/glog"
 	"github.com/myodc/go-micro/broker"
+	"github.com/myodc/go-micro/cmd"
 )
 
 var (
@@ -16,8 +18,11 @@ func pub() {
 	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))
+		if err := broker.Publish(topic, []byte(msg)); err != nil {
+			log.Errorf("[pub] failed: %v", err)
+		} else {
+			fmt.Println("[pub] pubbed message:", msg)
+		}
 		i++
 	}
 }
@@ -32,8 +37,14 @@ func sub() {
 }
 
 func main() {
-	broker.Init()
-	broker.Connect()
+	cmd.Init()
+
+	if err := broker.Init(); err != nil {
+		log.Fatalf("Broker Init error: %v", err)
+	}
+	if err := broker.Connect(); err != nil {
+		log.Fatalf("Broker Connect error: %v", err)
+	}
 
 	go pub()
 	go sub()