Browse Source

removing port fallback

afeiszli 3 years ago
parent
commit
46b2cfef1c
1 changed files with 3 additions and 4 deletions
  1. 3 4
      netclient/functions/mqpublish.go

+ 3 - 4
netclient/functions/mqpublish.go

@@ -169,6 +169,9 @@ func checkBroker(broker string, port string) error {
 	if broker == "" {
 	if broker == "" {
 		return errors.New("error: broker address is blank")
 		return errors.New("error: broker address is blank")
 	}
 	}
+	if port == "" {
+		return errors.New("error: broker port is blank")
+	}
 	_, err := net.LookupIP(broker)
 	_, err := net.LookupIP(broker)
 	if err != nil {
 	if err != nil {
 		return errors.New("nslookup failed for broker ... check dns records")
 		return errors.New("nslookup failed for broker ... check dns records")
@@ -178,10 +181,6 @@ func checkBroker(broker string, port string) error {
 	if err != nil {
 	if err != nil {
 		logger.Log(1, "error converting port to int: "+err.Error())
 		logger.Log(1, "error converting port to int: "+err.Error())
 	}
 	}
-	if intPort == 0 {
-		logger.Log(1, "port unset in config. Using default of 8883, which may be incorrect.")
-		intPort = 8883
-	}
 	pinger.SetTarget(&ping.Target{
 	pinger.SetTarget(&ping.Target{
 		Protocol: ping.TCP,
 		Protocol: ping.TCP,
 		Host:     broker,
 		Host:     broker,