Add missing lock

This commit is contained in:
Roland Shoemaker 2015-08-04 16:40:30 -07:00
parent ee24bd6bd3
commit 8e04f64e27
1 changed files with 2 additions and 0 deletions

View File

@ -397,7 +397,9 @@ func (rpc *AmqpRPCServer) Start(c cmd.Config) error {
rpc.processMessage(msg)
} else {
rpc.log.Info(" [!] Finished processing messages")
rpc.dMu.Lock()
rpc.done = true
rpc.dMu.Unlock()
blocking = false
}
case err = <-closeChan: