fixed a bug when setting zeromq ports

cpswarm · Jan 21, 2020 · 7349c84 · 7349c84
1 parent 7f400cc
commit 7349c84
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/manager/zeromq/server.go b/manager/zeromq/server.go
@@ -32,8 +32,8 @@ func SetupServer(pubPort, subPort string, keys map[string]string) (*zmqClient, e
 
 	c := &zmqClient{
 		conf: model.ZeromqServerInfo{
-			PubPort: os.Getenv(pubPort),
-			SubPort: os.Getenv(subPort),
+			PubPort: pubPort,
+			SubPort: subPort,
 		},
 		Pipe: model.NewPipe(),
 	}