问答 2023-12-05 来自:开发者社区

Apache RocketMQ中, 5.0.4版本的客户端调用过程中consumer为什么还能接收?

请问,在Apache RocketMQ中, 5.0.4版本的客户端 org.apache.rocketmq.client.apis.consumer.PushConsumer#close方法调用过程中,consumer为什么还会接收到新消息?

阿里云文档 2023-09-13

怎样让Consumer不立即消费消息并使消息重入队列_云消息队列 RabbitMQ 版( RabbitMQ)

您可以通过basicReject或basicNack方法否定应答消息,使消息重入队列,从而是其他Consumer可以消费消息。

阿里云文档 2023-08-09

Consumer如何否定应答消息并使其重入队列

您可以通过basicReject或basicNack方法否定应答消息,使消息重入队列,从而是其他Consumer可以消费消息。

阿里云文档 2023-05-24

RocketMQ消费者的原理架构

本文介绍云消息队列 RocketMQ 版中消费者(Consumer)的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。

文章 2022-01-05 来自:开发者社区

RocketMQ源码解析:手把手教老婆看懂consumer接收到的MessageExt

RocketMQ使用教程相关系列 目录目录源代码说明MessageExt的源码解析继承于Message,Message源码解析喝点毒鸡汤源代码说明MessageExt位于此包下:package org.apache.rocketmq.common.message;MessageExt的源码解析参数说明在代码里public class MessageExt extends Message { ...

RocketMQ源码解析:手把手教老婆看懂consumer接收到的MessageExt

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等