Skip to content

Commit

Permalink
[core] Pass to FairMQ tasks abstract namespace endpoint paths
Browse files Browse the repository at this point in the history
O2-5457
OCTRL-946
  • Loading branch information
teo committed Nov 25, 2024
1 parent 3f4a6f7 commit acfe0c8
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions core/task/channel/endpoint.go
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down Expand Up @@ -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,
}
}
Expand Down

0 comments on commit acfe0c8

Please sign in to comment.