如何使用redison为RBlockingQueue创建侦听器

Question

在我的一个服务中，我将添加到队列中：

RBlockingQueue<String> queue = redissonClient.getBlockingQueue("ABC");
queue.add(receivedTask.toString());

在第二个服务中，我连接到同一个redis实例，并希望在从第一个服务添加新元素后从队列中读取/弹出，如下所示：

RBlockingQueue<String> queue = redisClient.getRedissonClient().getBlockingDeque("ABC");
System.out.println("received: " +  queue.poll(0, TimeUnit.SECONDS));

我之前处理过RTopic，它运行得很好，但用例已经改变，现在必须使用RQueue。不确定我在这里做错了什么。

Answer 1

实际上发现我做错了什么。应该使用subscribeOnElements((：它通知侦听器并轮询可以访问的新元素。

queue.subscribeOnElements((msg) -> {
//code
});