diff --git a/src/WS/ClientSet.ts b/src/WS/ClientSet.ts
index 09099f1..8712e7f 100644
--- a/src/WS/ClientSet.ts
+++ b/src/WS/ClientSet.ts
@@ -1,6 +1,7 @@
 import Logger from "../Logger";
 import {SessionManager} from "../SessionManager";
 import {SmppSession} from "../SmppSession";
+import ZlibCoder from "../ZlibCoder";
 
 export class ClientSet {
 	identifier: string;
@@ -55,10 +56,11 @@ export class ClientSet {
 	}
 
 	notifyClients(message: string) {
+		let compressedMessage = ZlibCoder.compress(message);
 		if (this.clients.length > 0) {
 			this.logger.log2(`Notifying clients: ${message}`);
 			this.clients.forEach((ws) => {
-				ws.send(message);
+				ws.send(compressedMessage);
 			});
 		}
 	}
diff --git a/src/ZlibCoder.ts b/src/ZlibCoder.ts
index a77bb3c..bbe3e3d 100644
--- a/src/ZlibCoder.ts
+++ b/src/ZlibCoder.ts
@@ -2,7 +2,7 @@ const zlib = require("zlib");
 
 export default class ZlibCoder {
 	static compress(input: string): Buffer {
-		return zlib.compress(input);
+		return zlib.deflateSync(input).toString('base64');
 	}
 
 	static decompress(input: Buffer): string {