jboot的redis消息队列问题?

君子之耀 发布于 07/25 17:12
阅读 231
收藏 0

如题,基于redis实现的消息队列可以实现持久化吗?即redis服务重启之后,队列中的任务是否还存在?另外,我看代码中配置监听消息队列的时候,是void类型,如下,那么在onMessage中假设抛出一个异常,该任务还会被重新加入队列吗?

Jboot.me().getMq().addMessageListener(new JbootmqMessageListener(){
        @Override
        public void onMessage(String channel, Object obj) {
           System.out.println(obj);
        }
}, channel);

望海哥解答 @理工男海哥

加载中
0
理工男海哥
理工男海哥

redis的消息队列是没有持久化的,可以使用rabbitmq等来代替。

redis 的mq中,如果 onMessage 中抛出异常,不会再被重新加入队列,但是在 rabbitmq 会被重新加入队列(或者说是会重新通知)。

返回顶部
顶部