From b53f2ec388d211547e0bcaf5e29b3cdfebc58264 Mon Sep 17 00:00:00 2001 From: Shihao <327800885@qq.com> Date: Mon, 29 Apr 2024 08:49:54 +0800 Subject: [PATCH] Add getActiveTopic method to RPatternTopicReactive & RPatternTopicRx Signed-off-by: Shihao <327800885@qq.com> --- .../main/java/org/redisson/api/RPatternTopicReactive.java | 7 +++++++ .../src/main/java/org/redisson/api/RPatternTopicRx.java | 6 ++++++ 2 files changed, 13 insertions(+) diff --git a/redisson/src/main/java/org/redisson/api/RPatternTopicReactive.java b/redisson/src/main/java/org/redisson/api/RPatternTopicReactive.java index 5021b9f81..60c49238f 100644 --- a/redisson/src/main/java/org/redisson/api/RPatternTopicReactive.java +++ b/redisson/src/main/java/org/redisson/api/RPatternTopicReactive.java @@ -66,4 +66,11 @@ public interface RPatternTopicReactive { */ Mono removeListener(int listenerId); + + /** + * Returns active topic list of this pattern + * @return all actives channel of this pattern + */ + Mono> getActiveTopics(); + } diff --git a/redisson/src/main/java/org/redisson/api/RPatternTopicRx.java b/redisson/src/main/java/org/redisson/api/RPatternTopicRx.java index a05d35e8c..c190f7f9f 100644 --- a/redisson/src/main/java/org/redisson/api/RPatternTopicRx.java +++ b/redisson/src/main/java/org/redisson/api/RPatternTopicRx.java @@ -66,4 +66,10 @@ public interface RPatternTopicRx { */ void removeListener(int listenerId); + /** + * Returns active topic list of this pattern + * @return all actives topic of this pattern + */ + Single> getActiveTopics(); + }