From 9552484830858270b5db2640f2d881e1a5018683 Mon Sep 17 00:00:00 2001 From: sorie Date: Mon, 9 May 2022 23:30:37 +0800 Subject: [PATCH] fix rocketmq example code style. --- .../delay/RocketMQDelayConsumeApplication.java | 3 +-- .../examples/orderly/OrderlyMessageQueueSelector.java | 10 +++++----- 2 files changed, 6 insertions(+), 7 deletions(-) diff --git a/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-delay-consume-example/src/main/java/com/alibaba/cloud/examples/delay/RocketMQDelayConsumeApplication.java b/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-delay-consume-example/src/main/java/com/alibaba/cloud/examples/delay/RocketMQDelayConsumeApplication.java index 1dc210aff..dc031e122 100644 --- a/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-delay-consume-example/src/main/java/com/alibaba/cloud/examples/delay/RocketMQDelayConsumeApplication.java +++ b/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-delay-consume-example/src/main/java/com/alibaba/cloud/examples/delay/RocketMQDelayConsumeApplication.java @@ -48,8 +48,7 @@ public class RocketMQDelayConsumeApplication { } /** - * Produce delay messages - * @return + * Produce delay messages. */ @Bean public ApplicationRunner producerDelay() { diff --git a/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-orderly-consume-example/src/main/java/com/alibaba/cloud/examples/orderly/OrderlyMessageQueueSelector.java b/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-orderly-consume-example/src/main/java/com/alibaba/cloud/examples/orderly/OrderlyMessageQueueSelector.java index 2b5f9e980..1d8240f09 100644 --- a/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-orderly-consume-example/src/main/java/com/alibaba/cloud/examples/orderly/OrderlyMessageQueueSelector.java +++ b/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-orderly-consume-example/src/main/java/com/alibaba/cloud/examples/orderly/OrderlyMessageQueueSelector.java @@ -38,11 +38,11 @@ public class OrderlyMessageQueueSelector implements MessageQueueSelector { .getLogger(OrderlyMessageQueueSelector.class); /** - * to select a fixed queue by id - * @param mqs - * @param msg - * @param arg - * @return + * to select a fixed queue by id. + * @param mqs all message queues of this topic. + * @param msg mq message. + * @param arg mq arguments. + * @return message queue selected. */ @Override public MessageQueue select(List mqs, Message msg, Object arg) {