We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
【可选】客户端增加如下依赖:
<dependency> <groupId>com.sohu.tv</groupId> <artifactId>mq-client-open</artifactId> <version>4.9.3</version> </dependency>
当然可以使用RocketMQ原生客户端,但是客户端统计,版本等将无法上报。
初始化后设置
RocketMQConsumer和RocketMQProducer在调用start()方法前需要进行如下配置:
RocketMQConsumer
RocketMQProducer
start()
setMqCloudDomain("通用配置模块的domain");
其余的使用参照生产者接入或消费者接入。