From f2629fbda2d2b6a57316923eb822fcdbdaf5bceb Mon Sep 17 00:00:00 2001 From: Teo Mrnjavac Date: Wed, 30 Oct 2024 12:12:07 +0100 Subject: [PATCH] [core] Pass to FairMQ tasks abstract namespace endpoint paths O2-5457 OCTRL-946 --- core/task/channel/endpoint.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/task/channel/endpoint.go b/core/task/channel/endpoint.go index 75c27993..70b258fc 100644 --- a/core/task/channel/endpoint.go +++ b/core/task/channel/endpoint.go @@ -32,7 +32,7 @@ import ( "github.com/rs/xid" ) -const ipcPathFormat = "/tmp/o2ipc-%s" +const IPC_PATH_FORMAT = "@o2ipc-%s" type BindMap map[string]Endpoint @@ -90,7 +90,7 @@ func NewIpcEndpoint(path string, transport TransportType) Endpoint { func NewBoundIpcEndpoint(transport TransportType) Endpoint { return IpcEndpoint{ - Path: fmt.Sprintf(ipcPathFormat, xid.New().String()), + Path: fmt.Sprintf(IPC_PATH_FORMAT, xid.New().String()), Transport: transport, } }