From c8eabd5a8b2815f16f05fada1673fbb113acaece Mon Sep 17 00:00:00 2001 From: MiniDay <372403923@qq.com> Date: Mon, 29 Jan 2024 15:21:09 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=E5=BF=BD=E7=95=A5?= =?UTF-8?q?=E5=89=8D=E7=BC=80=E8=AE=A2=E9=98=85=E9=A2=91=E9=81=93=E7=9A=84?= =?UTF-8?q?=20API?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mc/plugin/ball/common/api/BallAPI.java | 38 +++++++++++++++++++ build.gradle.kts | 2 +- 2 files changed, 39 insertions(+), 1 deletion(-) 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 ccac5d0..d567091 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 @@ -460,6 +460,11 @@ public abstract class BallAPI { } } + /** + * 订阅 redis 消息频道 + * + * @param channel 频道名称 + */ public void subscribe(@NotNull String... channel) { for (int i = 0; i < channel.length; i++) { channel[i] = ballConfig.getChannelPrefix() + channel[i]; @@ -467,10 +472,29 @@ public abstract class BallAPI { redisPub.sync().subscribe(channel); } + /** + * 忽略仓鼠球频道前缀配置,订阅 redis 消息频道 + * + * @param channel 频道名称 + */ + public void subscribeIgnorePrefix(@NotNull String... channel) { + redisPub.sync().subscribe(channel); + } + + /** + * 订阅 redis 消息频道(正则) + * + * @param patterns 频道名称正则表达式 + */ public void subscribePatterns(@NotNull String patterns) { redisPub.sync().psubscribe(patterns); } + /** + * 取消订阅 redis 频道 + * + * @param channel 频道名称 + */ public void unsubscribe(@NotNull String... channel) { for (int i = 0; i < channel.length; i++) { channel[i] = ballConfig.getChannelPrefix() + channel[i]; @@ -478,6 +502,20 @@ public abstract class BallAPI { redisPub.sync().unsubscribe(channel); } + /** + * 忽略仓鼠球频道前缀配置,取消订阅 redis 频道 + * + * @param channel 频道名称 + */ + public void unsubscribeIgnorePrefix(@NotNull String... channel) { + redisPub.sync().unsubscribe(channel); + } + + /** + * 取消订阅 redis 消息频道(正则) + * + * @param patterns 频道名称正则表达式 + */ public void unsubscribePatterns(@NotNull String patterns) { redisPub.sync().punsubscribe(patterns); } diff --git a/build.gradle.kts b/build.gradle.kts index 6b0e8bd..e5b08ec 100644 --- a/build.gradle.kts +++ b/build.gradle.kts @@ -5,7 +5,7 @@ plugins { } group = "cn.hamster3.mc.plugin" -version = "1.5.0" +version = "1.5.1" subprojects { apply {