diff --git a/src/main/java/net/krakatoaapi/KrakatoaAPI.java b/src/main/java/net/krakatoaapi/KrakatoaAPI.java
index 8bfbb92..0cc8c31 100644
--- a/src/main/java/net/krakatoaapi/KrakatoaAPI.java
+++ b/src/main/java/net/krakatoaapi/KrakatoaAPI.java
@@ -54,7 +54,8 @@ public class KrakatoaAPI extends JavaPlugin {
     KraSocketClientConfig kraSocketClientConfig = new KraSocketClientConfig(
         this.configHandler.getWebSocketProtocol(), this.configHandler.getWebSocketHost(),
         this.configHandler.getWebSocketPort(), this.configHandler.getWebSocketAccessKey(),
-        CloudNetDriver.getInstance().getComponentName());
+        CloudNetDriver.getInstance().getComponentName(),
+        this.configHandler.getWebSocketAckTimeouts());
 
     this.kraSocketClientEventInitiater = new KraSocketClientEventInitiater();
     this.kraSocketClientEventInterface = new SocketClientMessageListener();
@@ -81,7 +82,7 @@ public class KrakatoaAPI extends JavaPlugin {
           KraSocketClientProtocolStatus.SEND.getStatus(), 0,
           KraSocketClientProtocolDest.PROXY.getStatus(), "c7b023ac03034275923d3a1028e887a0",
           (short) 59739,
-          CloudNetDriver.getInstance().getComponentName());
+          CloudNetDriver.getInstance().getComponentName(), null);
 
       this.kraSocketClient.getSocketClient().SendMessage(kraSocketClientProtocolMessage);
     }, 3 * 20);
diff --git a/src/main/java/net/krakatoaapi/event/SocketMessageEvent.java b/src/main/java/net/krakatoaapi/event/SocketMessageEvent.java
index 543bdd7..46e5811 100644
--- a/src/main/java/net/krakatoaapi/event/SocketMessageEvent.java
+++ b/src/main/java/net/krakatoaapi/event/SocketMessageEvent.java
@@ -1,5 +1,7 @@
 package net.krakatoaapi.event;
 
+import earth.krakatao.protocol.KraSocketClientProtocolMessage;
+import java.util.function.Consumer;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import lombok.Setter;
@@ -22,6 +24,7 @@ public class SocketMessageEvent extends Event {
   private final String uuid;
   private final int commandNumber;
   private final String args;
+  private final Consumer<KraSocketClientProtocolMessage> messageConsumer;
 
   public static HandlerList getHandlerList() {
     return handlers;
diff --git a/src/main/java/net/krakatoaapi/listener/SocketClientMessageListener.java b/src/main/java/net/krakatoaapi/listener/SocketClientMessageListener.java
index c21942d..8d6f35e 100644
--- a/src/main/java/net/krakatoaapi/listener/SocketClientMessageListener.java
+++ b/src/main/java/net/krakatoaapi/listener/SocketClientMessageListener.java
@@ -23,7 +23,8 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac
               kraSocketClientProtocolMessage.getDest(),
               kraSocketClientProtocolMessage.getUuid(),
               kraSocketClientProtocolMessage.getCmdNumber(),
-              kraSocketClientProtocolMessage.getArgs()));
+              kraSocketClientProtocolMessage.getArgs(),
+              kraSocketClientProtocolMessage.getMessageConsumer()));
     });
   }