Merge pull request #587 from benburkert/shutdown-method

replace label & goto with a method
IBM · Dec 21, 2015 · d7ff2eb · d7ff2eb
2 parents bb163bf + 29d4b91
commit d7ff2eb
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/async_producer.go b/async_producer.go
@@ -581,7 +581,8 @@ func (bp *brokerProducer) run() {
 		select {
 		case msg := <-bp.input:
 			if msg == nil {
-				goto shutdown
+				bp.shutdown()
+				return
 			}
 
 			if msg.flags&syn == syn {
@@ -637,8 +638,9 @@ func (bp *brokerProducer) run() {
 			output = nil
 		}
 	}
+}
 
-shutdown:
+func (bp *brokerProducer) shutdown() {
 	for !bp.buffer.empty() {
 		select {
 		case response := <-bp.responses: