Log when message not acknowledged and comments

client.go

@@ -215,6 +215,9 @@ var ErrNotConnected = errors.New("not Connected")
 // Connect will create a connection to the message broker, by default
 // it will attempt to connect at v3.1.1 and auto retry at v3.1 if that
 // fails
+// Note: If using QOS1+ and CleanSession=false it is advisable to add
+// routes (or a DefaultPublishHandler) prior to calling Connect()
+// because queued messages may be delivered immediatly post connection
 func (c *client) Connect() Token {
 	t := newToken(packets.Connect).(*ConnectToken)
 	DEBUG.Println(CLI, "Connect()")

router.go

@@ -152,14 +152,18 @@ func (r *router) matchAndDispatch(messages <-chan *packets.PublishPacket, order
 				sent = true
 			}
 		}
-		if !sent && r.defaultHandler != nil {
-			if order {
-				handlers = append(handlers, r.defaultHandler)
+		if !sent {
+			if r.defaultHandler != nil {
+				if order {
+					handlers = append(handlers, r.defaultHandler)
+				} else {
+					go func() {
+						r.defaultHandler(client, m)
+						m.Ack()
+					}()
+				}
 			} else {
-				go func() {
-					r.defaultHandler(client, m)
-					m.Ack()
-				}()
+				DEBUG.Println(ROU, "matchAndDispatch received message and no handler was available. Message will NOT be acknowledged.")
 			}
 		}
 		r.RUnlock()