diff --git a/docker-compose.yaml b/docker-compose.yaml index ac37a7f..47c3bd4 100644 --- a/docker-compose.yaml +++ b/docker-compose.yaml @@ -75,4 +75,4 @@ services: volumes: shared_socket: - driver: local \ No newline at end of file + driver: local diff --git a/pkg/main.go b/pkg/main.go index d443005..b1413a4 100644 --- a/pkg/main.go +++ b/pkg/main.go @@ -33,11 +33,17 @@ func main() { panic(err) } - requestMiddleWareAddress := helpers.GetEnv("REQUEST_MIDDLEWARES_SOCKET", "") - requestMiddleware := middleware.NewMiddlewareManager(msgCh1, msgCh2, requestMiddleWareAddress) - - responseMiddleWareAddress := helpers.GetEnv("RESPONSE_MIDDLEWARES_SOCKET", "") - responseMiddleware := middleware.NewMiddlewareManager(ackCh2, ackCh1, responseMiddleWareAddress) + requestMiddleware := middleware.NewMiddlewareManager( + msgCh1, + msgCh2, + helpers.GetEnv("REQUEST_MIDDLEWARES_SOCKET", ""), + ) + + responseMiddleware := middleware.NewMiddlewareManager( + ackCh2, + ackCh1, + helpers.GetEnv("RESPONSE_MIDDLEWARES_SOCKET", ""), + ) go reader.Start() go requestMiddleware.Start()