|
|
@ -35,9 +35,9 @@ export abstract class IpcServerService<M extends Microservice = Microservice> ex |
|
|
|
public bootIpc(ipc: IPC) { |
|
|
|
return new Promise<void>(async (resolve) => { |
|
|
|
// Create the socket directory if it doesn't exist
|
|
|
|
await mkdir(dirname(this.socketPath), { recursive: true }); |
|
|
|
await mkdir(dirname(this.SOCKET_PATH), { recursive: true }); |
|
|
|
// Serve the IPC server
|
|
|
|
ipc.serve(this.socketPath, () => { |
|
|
|
ipc.serve(this.SOCKET_PATH, () => { |
|
|
|
this.__server = ipc.server; |
|
|
|
this.installMessageHandlers(); |
|
|
|
resolve(); |
|
|
|