Merge pull request #95 from mreiferson/stop_panic_95

nsq_to_nsq: panic on shutdown

consumer.go

@@ -982,7 +982,12 @@ func (r *Consumer) Stop() {
 		}
 
 		time.AfterFunc(time.Second*30, func() {
-			r.stopHandlers()
+			// if we've waited this long handlers are blocked on processing messages
+			// so we can't just stopHandlers (if any adtl. messages were pending processing
+			// we would cause a panic on channel close)
+			//
+			// instead, we just bypass handler closing and skip to the final exit
+			r.exit()
 		})
 	}
 }