add checks for nil mqclient

mq/util.go

@@ -65,6 +65,9 @@ func publish(node *models.Node, dest string, msg []byte) error {
 	if encryptErr != nil {
 		return encryptErr
 	}
+	if mqclient == nil {
+		return errors.New("cannot publish mqclient not connected")
+	}
 	if token := mqclient.Publish(dest, 0, true, encrypted); !token.WaitTimeout(MQ_TIMEOUT*time.Second) || token.Error() != nil {
 		var err error
 		if token.Error() == nil {

netclient/functions/mqpublish.go

@@ -146,6 +146,9 @@ func publish(nodeCfg *config.ClientConfig, dest string, msg []byte, qos byte) er
 	if err != nil {
 		return err
 	}
+	if mqclient == nil {
+		return errors.New("unable to publish - no mqclient")
+	}
 
 	if token := mqclient.Publish(dest, qos, false, encrypted); !token.WaitTimeout(30*time.Second) || token.Error() != nil {
 		logger.Log(0, "could not connect to broker at "+nodeCfg.Server.Server+":"+nodeCfg.Server.MQPort)