opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-30 18:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #3949] Update maven-checkstyle-plugin version

Browse Source
This commit is contained in:
zhouxiang
2022-06-09 14:16:52 +08:00
parent e5430c5626
commit c3059933e5
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
example/src/main/java/org/apache/rocketmq/example/namespace/PullConsumerWithNamespace.java
+1 -1
View File
@@ -79,7 +79,7 @@ public class PullConsumerWithNamespace {
return;
}
pullResult.getMsgFoundList().stream().forEach(
(msg) -> System.out.printf("Topic is:%s, msgId is:%s%n" , msg.getTopic(), msg.getMsgId()));
msg -> System.out.printf("Topic is:%s, msgId is:%s%n" , msg.getTopic(), msg.getMsgId()));
}
private static void putMessageQueueOffset(MessageQueue mq, long offset) {
example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
+1 -1
View File
@@ -26,7 +26,7 @@ public class PushConsumerWithNamespace {
defaultMQPushConsumer.setNamesrvAddr("127.0.0.1:9876");
defaultMQPushConsumer.subscribe("topicTest", "*");
defaultMQPushConsumer.registerMessageListener((MessageListenerConcurrently)(msgs, context) -> {
msgs.stream().forEach((msg) -> {
msgs.stream().forEach(msg -> {
System.out.printf("Msg topic is:%s, MsgId is:%s, reconsumeTimes is:%s%n", msg.getTopic() , msg.getMsgId(), msg.getReconsumeTimes());
});
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
pom.xml
+1 -1
View File
@@ -206,7 +206,7 @@
</plugin>
<plugin>
<artifactId>maven-checkstyle-plugin</artifactId>
<version>2.17</version>
<version>3.1.2</version>
<executions>
<execution>
<id>verify</id>