From 7349c8403eb0e8441d4a330fe296f466b953069e Mon Sep 17 00:00:00 2001
From: Farshid Tavakolizadeh <email@farshid.ws>
Date: Tue, 21 Jan 2020 15:15:53 +0100
Subject: [PATCH] fixed a bug when setting zeromq ports

---
 manager/zeromq/server.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/manager/zeromq/server.go b/manager/zeromq/server.go
index ca23444..7454a9a 100644
--- 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(),
 	}