Fix rocketmq code style

spring-cloud-alibaba-examples/rocketmq-example/rocketmq-pollable-consume-example/src/main/java/com/alibaba/cloud/examples/pollable/RocketMQPollableConsumeApplication.java

@@ -71,12 +71,13 @@ public class RocketMQPollableConsumeApplication {
 			while (true) {
 				try {
 					if (!destIn.poll((m) -> {
-						SimpleMsg newPayload = (SimpleMsg)m.getPayload();
+						SimpleMsg newPayload = (SimpleMsg) m.getPayload();
 						System.out.println(newPayload.getMsg());
-					}, new ParameterizedTypeReference<SimpleMsg>() {})) {
+					}, new ParameterizedTypeReference<SimpleMsg>() { })) {
 						Thread.sleep(1000);
 					}
-				} catch (Exception e) {
+				}
+				catch (Exception e) {
 					// handle failure
 				}
 			}

spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/RocketMQMessageChannelBinder.java

@@ -16,7 +16,6 @@
 
 package com.alibaba.cloud.stream.binder.rocketmq;
 
-import com.alibaba.cloud.stream.binder.rocketmq.constant.RocketMQConst;
 import com.alibaba.cloud.stream.binder.rocketmq.custom.RocketMQBeanContainerCache;
 import com.alibaba.cloud.stream.binder.rocketmq.extend.ErrorAcknowledgeHandler;
 import com.alibaba.cloud.stream.binder.rocketmq.integration.inbound.RocketMQInboundChannelAdapter;

spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/convert/RocketMQMessageConverter.java

@@ -20,7 +20,12 @@ import java.util.ArrayList;
 import java.util.List;
 
 import org.springframework.messaging.Message;
-import org.springframework.messaging.converter.*;
+import org.springframework.messaging.converter.AbstractMessageConverter;
+import org.springframework.messaging.converter.ByteArrayMessageConverter;
+import org.springframework.messaging.converter.CompositeMessageConverter;
+import org.springframework.messaging.converter.MappingJackson2MessageConverter;
+import org.springframework.messaging.converter.MessageConverter;
+import org.springframework.messaging.converter.StringMessageConverter;
 import org.springframework.util.ClassUtils;
 
 /**
@@ -110,7 +115,8 @@ public class RocketMQMessageConverter extends AbstractMessageConverter {
 		for (MessageConverter converter : getMessageConverter().getConverters()) {
 			try {
 				payload = converter.fromMessage(message, targetClass);
-			} catch (Exception ignore) {
+			}
+			catch (Exception ignore) {
 			}
 			if (payload != null) {
 				return payload;

spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/integration/inbound/RocketMQConsumerFactory.java

@@ -96,7 +96,7 @@ public final class RocketMQConsumerFactory {
 
 	/**
 	 * todo Compatible with versions less than 4.6 ?
-	 * @param topic
+	 * @param topic consumer topic.
 	 * @param extendedConsumerProperties extendedConsumerProperties
 	 * @return DefaultLitePullConsumer
 	 */