|
|
@@ -13,7 +13,7 @@ import org.springframework.stereotype.Service;
|
|
|
@Slf4j
|
|
|
@AllArgsConstructor
|
|
|
@RocketMQMessageListener(
|
|
|
- consumerGroup = "${rocketmq.consumer.group}", topic = "test-add-topic", consumeMode = ConsumeMode.CONCURRENTLY)
|
|
|
+ consumerGroup = "${rocketmq.consumer.group}", topic = "test-add-topic", consumeMode = ConsumeMode.ORDERLY)
|
|
|
public class TestConsumer implements RocketMQListener<MyMqEvent> {
|
|
|
|
|
|
@SneakyThrows
|
