fix rocketmq example code style.

pull/2570/head
sorie 3 years ago
parent 58d58f8a48
commit 9552484830

@ -48,8 +48,7 @@ public class RocketMQDelayConsumeApplication {
} }
/** /**
* Produce delay messages * Produce delay messages.
* @return
*/ */
@Bean @Bean
public ApplicationRunner producerDelay() { public ApplicationRunner producerDelay() {

@ -38,11 +38,11 @@ public class OrderlyMessageQueueSelector implements MessageQueueSelector {
.getLogger(OrderlyMessageQueueSelector.class); .getLogger(OrderlyMessageQueueSelector.class);
/** /**
* to select a fixed queue by id * to select a fixed queue by id.
* @param mqs * @param mqs all message queues of this topic.
* @param msg * @param msg mq message.
* @param arg * @param arg mq arguments.
* @return * @return message queue selected.
*/ */
@Override @Override
public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) { public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) {

Loading…
Cancel
Save