diff --git a/packages/ipc/src/AbstractIpcService.ts b/packages/ipc/src/AbstractIpcService.ts
index d1f1fd1..b8a32cc 100644
--- a/packages/ipc/src/AbstractIpcService.ts
+++ b/packages/ipc/src/AbstractIpcService.ts
@@ -39,7 +39,7 @@ export default abstract class AbstractIpcService<M extends Microservice = Micros
 	/**
 	 * Boot the IPC service
 	 */
-	public async boot() {
+	public override async boot() {
 		// Create the IPC socket
 		this.__ipc = new RawIPC.IPC();
 		this.__ipc.config.id = this.NAME;
@@ -51,7 +51,7 @@ export default abstract class AbstractIpcService<M extends Microservice = Micros
 	/**
 	 * Shutdown the IPC service
 	 */
-	public async shutdown() {
+	public override async shutdown() {
 		await this.shutdownIpc(this.__ipc);
 		this.__ipc = null;
 	}
diff --git a/packages/ipc/src/IpcServerService.ts b/packages/ipc/src/IpcServerService.ts
index ee2185c..711a2c5 100644
--- a/packages/ipc/src/IpcServerService.ts
+++ b/packages/ipc/src/IpcServerService.ts
@@ -86,6 +86,8 @@ export abstract class IpcServerService<M extends Microservice = Microservice> ex
 		if (this.__server === null) {
 			return;
 		}
-		this.__server.emit(method, data);
+		for (let socket of <Socket[]>(<any>this.__server).sockets) {
+			this.__server.emit(socket, method, data);
+		}
 	}
 }