diff --git a/ball-bukkit/src/main/java/cn/hamster3/mc/plugin/ball/bukkit/api/BallBukkitAPI.java b/ball-bukkit/src/main/java/cn/hamster3/mc/plugin/ball/bukkit/api/BallBukkitAPI.java index 5b1704a..8911bf9 100644 --- a/ball-bukkit/src/main/java/cn/hamster3/mc/plugin/ball/bukkit/api/BallBukkitAPI.java +++ b/ball-bukkit/src/main/java/cn/hamster3/mc/plugin/ball/bukkit/api/BallBukkitAPI.java @@ -59,7 +59,7 @@ public class BallBukkitAPI extends BallAPI { BallConfig ballConfig = new BallConfig( config.getBoolean("debug", false), RedisClient.create(config.getString("redis-url")), - config.getString("channel-prefix", ""), + config.getString("channel-prefix", "") + ":", config.getBoolean("game-server-update-player-info", false), serverInfo, datasource diff --git a/ball-bungee/src/main/java/cn/hamster3/mc/plugin/core/bungee/api/BallBungeeCordAPI.java b/ball-bungee/src/main/java/cn/hamster3/mc/plugin/core/bungee/api/BallBungeeCordAPI.java index 3dc362e..aeeeb8e 100644 --- a/ball-bungee/src/main/java/cn/hamster3/mc/plugin/core/bungee/api/BallBungeeCordAPI.java +++ b/ball-bungee/src/main/java/cn/hamster3/mc/plugin/core/bungee/api/BallBungeeCordAPI.java @@ -56,7 +56,7 @@ public class BallBungeeCordAPI extends BallAPI { BallConfig ballConfig = new BallConfig( config.getBoolean("debug", false), RedisClient.create(config.getString("redis-url")), - config.getString("channel-prefix", ""), + config.getString("channel-prefix", "") + ":", config.getBoolean("game-server-update-player-info", false), serverInfo, datasource diff --git a/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java b/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java index 3eed97b..e4a95b3 100644 --- a/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java +++ b/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/api/BallAPI.java @@ -448,7 +448,7 @@ public abstract class BallAPI { */ public void sendBallMessage(@NotNull String channel, @NotNull BallMessage message, boolean prefix, boolean block) { if (prefix) { - channel = ballConfig.getChannelPrefix() + ":" + channel; + channel = ballConfig.getChannelPrefix() + channel; } if (block) { pubConnection.sync().publish(channel, message); @@ -466,7 +466,7 @@ public abstract class BallAPI { public void subscribe(@NotNull String... channel) { for (int i = 0; i < channel.length; i++) { - channel[i] = ballConfig.getChannelPrefix() + ":" + channel[i]; + channel[i] = ballConfig.getChannelPrefix() + channel[i]; } subConnection.sync().subscribe(channel); } @@ -477,7 +477,7 @@ public abstract class BallAPI { public void unsubscribe(@NotNull String... channel) { for (int i = 0; i < channel.length; i++) { - channel[i] = ballConfig.getChannelPrefix() + ":" + channel[i]; + channel[i] = ballConfig.getChannelPrefix() + channel[i]; } subConnection.sync().unsubscribe(channel); } diff --git a/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/listener/BallRedisListener.java b/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/listener/BallRedisListener.java index 4ccfae0..aa0037c 100644 --- a/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/listener/BallRedisListener.java +++ b/ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/listener/BallRedisListener.java @@ -19,6 +19,9 @@ public class BallRedisListener implements RedisPubSubListener