|
|
@ -15,9 +15,9 @@ export default abstract class AbstractIpcService<M extends Microservice = Micros |
|
|
|
// Implementation Requirements -----------------------------------------------------------------
|
|
|
|
|
|
|
|
/** |
|
|
|
* The path to the socket file |
|
|
|
*/ |
|
|
|
protected abstract readonly SOCKET_PATH: string; |
|
|
|
* The path to the socket file |
|
|
|
*/ |
|
|
|
protected abstract readonly SOCKET_PATH: string; |
|
|
|
|
|
|
|
/** |
|
|
|
* Add a message handler for the service |
|
|
@ -37,16 +37,16 @@ export default abstract class AbstractIpcService<M extends Microservice = Micros |
|
|
|
// Service Management --------------------------------------------------------------------------
|
|
|
|
|
|
|
|
/** |
|
|
|
* Boot the IPC service |
|
|
|
*/ |
|
|
|
public async boot() { |
|
|
|
// Create the IPC socket
|
|
|
|
this.__ipc = new RawIPC.IPC(); |
|
|
|
this.__ipc.config.id = this.NAME; |
|
|
|
this.__ipc.config.retry = 1500; |
|
|
|
this.__ipc.config.silent = true; |
|
|
|
* Boot the IPC service |
|
|
|
*/ |
|
|
|
public async boot() { |
|
|
|
// Create the IPC socket
|
|
|
|
this.__ipc = new RawIPC.IPC(); |
|
|
|
this.__ipc.config.id = this.NAME; |
|
|
|
this.__ipc.config.retry = 1500; |
|
|
|
this.__ipc.config.silent = true; |
|
|
|
await this.bootIpc(this.__ipc); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* Shutdown the IPC service |
|
|
|