diff --git a/serversync-common/src/main/java/me/akraml/serversync/broker/MessageBrokerService.java b/serversync-common/src/main/java/me/akraml/serversync/broker/MessageBrokerService.java
index 47a1f72..98d80a4 100644
--- a/serversync-common/src/main/java/me/akraml/serversync/broker/MessageBrokerService.java
+++ b/serversync-common/src/main/java/me/akraml/serversync/broker/MessageBrokerService.java
@@ -250,6 +250,7 @@ public void publishCreate(final String serverName,
                               final int port,
                               final int maxPlayers) {
         final JsonObject jsonObject = new JsonObject();
+        jsonObject.addProperty("type", ServerMessageType.CREATE.name());
         jsonObject.addProperty("name", serverName);
         jsonObject.addProperty("ip", ip);
         jsonObject.addProperty("port", port);