refactor & upgrade rocketmq-client version

spring-cloud-alibaba-dependencies/pom.xml

@@ -27,7 +27,7 @@
         <aliyun.sdk.version>4.0.1</aliyun.sdk.version>
         <alicloud.context.version>1.0.5</alicloud.context.version>
         <aliyun.sdk.edas.version>2.16.0</aliyun.sdk.edas.version>
-        <rocketmq.starter.version>2.0.2-SNAPSHOT</rocketmq.starter.version>
+        <rocketmq.starter.version>2.0.2</rocketmq.starter.version>
         <schedulerX.client.version>2.1.6</schedulerX.client.version>
         <dubbo.version>2.6.5</dubbo.version>
         <dubbo-spring-boot.version>0.2.1.RELEASE</dubbo-spring-boot.version>

spring-cloud-alibaba-examples/rocketmq-example/rocketmq-produce-example/src/main/java/org/springframework/cloud/alibaba/cloud/examples/TransactionListenerImpl.java

@@ -16,12 +16,9 @@
 
 package org.springframework.cloud.alibaba.cloud.examples;
 
-import java.util.HashMap;
-
 import org.apache.rocketmq.spring.annotation.RocketMQTransactionListener;
 import org.apache.rocketmq.spring.core.RocketMQLocalTransactionListener;
 import org.apache.rocketmq.spring.core.RocketMQLocalTransactionState;
-import org.apache.rocketmq.spring.support.RocketMQHeaders;
 import org.springframework.messaging.Message;
 
 /**
@@ -32,8 +29,7 @@ public class TransactionListenerImpl implements RocketMQLocalTransactionListener
 	@Override
 	public RocketMQLocalTransactionState executeLocalTransaction(Message msg,
 			Object arg) {
-		Object num = ((HashMap) msg.getHeaders().get(RocketMQHeaders.PROPERTIES))
-				.get("USERS_test");
+		Object num = msg.getHeaders().get("test");
 
 		if ("1".equals(num)) {
 			System.out.println(
@@ -55,4 +51,4 @@ public class TransactionListenerImpl implements RocketMQLocalTransactionListener
 		System.out.println("check: " + new String((byte[]) msg.getPayload()));
 		return RocketMQLocalTransactionState.COMMIT;
 	}
-}
+}

spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/RocketMQBinderUtils.java

@@ -25,7 +25,7 @@ import org.springframework.util.StringUtils;
  */
 public class RocketMQBinderUtils {
 
-	public static RocketMQBinderConfigurationProperties mergeProducerProperties(
+	public static RocketMQBinderConfigurationProperties mergeProperties(
 			RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties,
 			RocketMQProperties rocketMQProperties) {
 		RocketMQBinderConfigurationProperties result = new RocketMQBinderConfigurationProperties();

spring-cloud-stream-binder-rocketmq/src/main/java/org/springframework/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java

@@ -87,7 +87,7 @@ public class RocketMQMessageChannelBinder extends
 		if (producerProperties.getExtension().getEnabled()) {
 
 			RocketMQBinderConfigurationProperties mergedProperties = RocketMQBinderUtils
-					.mergeProducerProperties(rocketBinderConfigurationProperties,
+					.mergeProperties(rocketBinderConfigurationProperties,
 							rocketMQProperties);
 
 			RocketMQTemplate rocketMQTemplate;