Upgrade rocketmq client version to 5.3.1
diff --git a/rocketmq-spring-boot-parent/pom.xml b/rocketmq-spring-boot-parent/pom.xml
index 3668cff..5671af8 100644
--- a/rocketmq-spring-boot-parent/pom.xml
+++ b/rocketmq-spring-boot-parent/pom.xml
@@ -42,7 +42,7 @@
<rocketmq.spring.boot.version>2.3.2-SNAPSHOT</rocketmq.spring.boot.version>
- <rocketmq.version>5.3.0</rocketmq.version>
+ <rocketmq.version>5.3.1</rocketmq.version>
<slf4j.version>1.7.25</slf4j.version>
<jackson.version>2.11.1</jackson.version>
<fastjson.version>1.2.83</fastjson.version>
diff --git a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
index 0136fc3..ed2a5de 100644
--- a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
+++ b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/RocketMQUtil.java
@@ -269,7 +269,7 @@
if (isEnableMsgTrace) {
try {
- AsyncTraceDispatcher dispatcher = new AsyncTraceDispatcher(groupName, TraceDispatcher.Type.PRODUCE, customizedTraceTopic, isEnableAcl ? new AclClientRPCHook(new SessionCredentials(ak, sk)) : null);
+ AsyncTraceDispatcher dispatcher = new AsyncTraceDispatcher(groupName, TraceDispatcher.Type.PRODUCE, 10, customizedTraceTopic, isEnableAcl ? new AclClientRPCHook(new SessionCredentials(ak, sk)) : null);
dispatcher.setHostProducer(producer.getDefaultMQProducerImpl());
Field field = DefaultMQProducer.class.getDeclaredField("traceDispatcher");
field.setAccessible(true);
@@ -285,9 +285,9 @@
}
public static DefaultLitePullConsumer createDefaultLitePullConsumer(String nameServer, String accessChannel,
- String groupName, String topicName, MessageModel messageModel, SelectorType selectorType,
- String selectorExpression, String ak, String sk, int pullBatchSize, boolean useTLS)
- throws MQClientException {
+ String groupName, String topicName, MessageModel messageModel, SelectorType selectorType,
+ String selectorExpression, String ak, String sk, int pullBatchSize, boolean useTLS)
+ throws MQClientException {
DefaultLitePullConsumer litePullConsumer = null;
if (StringUtils.hasLength(ak) && StringUtils.hasLength(sk)) {
litePullConsumer = new DefaultLitePullConsumer(groupName, new AclClientRPCHook(new SessionCredentials(ak, sk)));
