Adding a nil check to net.go.

eclipse-paho · Sep 18, 2018 · 0a0770a · 0a0770a
1 parent 88c4622
commit 0a0770a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/net.go b/net.go
@@ -201,7 +201,9 @@ func outgoing(c *client) {
 			DEBUG.Println(NET, "obound priority msg to write, type", reflect.TypeOf(msg.p))
 			if err := msg.p.Write(c.conn); err != nil {
 				ERROR.Println(NET, "outgoing stopped with error", err)
-				msg.t.setError(err)
+				if msg.t != nil {
+					msg.t.setError(err)
+				}
 				signalError(c.errors, err)
 				return
 			}