From 81870aeb1ab33faf1f8faa81c2a08c6355041088 Mon Sep 17 00:00:00 2001
From: Martin Boehm <martin.boehm@1mbsoftware.net>
Date: Mon, 28 May 2018 10:45:29 +0200
Subject: [PATCH] Change ZeroMQ shutdown synchronization

---
 bchain/mq.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/bchain/mq.go b/bchain/mq.go
index 299fcc19..153b5997 100644
--- a/bchain/mq.go
+++ b/bchain/mq.go
@@ -67,8 +67,8 @@ func (mq *MQ) run(callback func(NotificationType)) {
 			glog.Error("MQ loop recovered from ", r)
 		}
 		mq.isRunning = false
-		close(mq.finished)
 		glog.Info("MQ loop terminated")
+		mq.finished <- true
 	}()
 	mq.isRunning = true
 	for {
@@ -117,7 +117,7 @@ func (mq *MQ) Shutdown() error {
 		if err := mq.context.Term(); err != nil {
 			return err
 		}
-		_, _ = <-mq.finished
+		<-mq.finished
 		glog.Info("MQ server shutdown finished")
 	}
 	return nil