Skip to content

Commit 405f4b8

Browse files
committed
feat: fix redis admin spi.
1 parent bad85fd commit 405f4b8

File tree

2 files changed

+1
-1
lines changed

2 files changed

+1
-1
lines changed

eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/admin/RedisAdmin.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ public RedisAdmin() {
4242

4343
@Override
4444
public List<TopicProperties> getTopic() throws Exception {
45+
// TODO: match all the topic with pattern "*" for now.
4546
RPatternTopic patternTopic = redisson.getPatternTopic("*");
4647
return patternTopic.getPatternNames()
4748
.stream()

eventmesh-storage-plugin/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/consumer/RedisConsumer.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@
3939
@Slf4j
4040
public class RedisConsumer implements Consumer {
4141

42-
4342
private Redisson redisson;
4443

4544
private EventMeshMessageListener messageListener;

0 commit comments

Comments
 (0)