Merge pull request #472 from ChIoT-Tech/master

Resolve issue introduced in pull request #470 (missing continue).
eclipse-paho · Dec 21, 2020 · cef02e8 · cef02e8
2 parents fbe4d12 + 2d6fd16
commit cef02e8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/client.go b/client.go
@@ -530,6 +530,7 @@ func (c *client) startCommsWorkers(conn net.Conn, inboundFromStore <-chan packet
 				if !ok {
 					ackOut = nil     // ignore channel going forward
 					c.workers.Done() // matchAndDispatch has completed
+					continue         // await next message
 				}
 				commsoboundP <- msg
 			case <-c.stop: