From 0daeeda190f87ffb2d8d6a30f4da690fd58d684d Mon Sep 17 00:00:00 2001
From: Matt Goodall <matt.goodall@gmail.com>
Date: Tue, 23 Apr 2013 09:16:08 +0100
Subject: [PATCH] Report and exit on unexpected error.

---
 throughput.go | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/throughput.go b/throughput.go
index 9adfe90..a6138aa 100644
--- a/throughput.go
+++ b/throughput.go
@@ -51,7 +51,12 @@ func producer(args []string) {
 	}()
 
 	for stanza := range x.In {
-		log.Println(stanza)
+		switch v := stanza.(type) {
+		case error:
+			log.Fatal(v)
+		default:
+			log.Println(stanza)
+		}
 	}
 }
 
@@ -95,8 +100,11 @@ func consumer(args []string) {
 	}()
 
 	for stanza := range x.In {
-		if _, ok := stanza.(*xmpp.Message); ok {
+		switch v := stanza.(type) {
+		case *xmpp.Message:
 			count++
+		case error:
+			log.Fatal(v)
 		}
 	}
 }