You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/10/31 09:40:56 UTC

[incubator-eventmesh] branch master updated: style(RocketMQBinaryMessageReader.java): Lambda can be replaced with call qualifier

This is an automated email from the ASF dual-hosted git repository.

mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


The following commit(s) were added to refs/heads/master by this push:
     new 418f4847 style(RocketMQBinaryMessageReader.java): Lambda can be replaced with call qualifier
     new 50cdeea3 Merge pull request #1981 from dinghuang/master
418f4847 is described below

commit 418f4847eb9e0a9289d4aed2cdd1ce1c6c44ca84
Author: dinghuang <di...@gmail.com>
AuthorDate: Thu Oct 27 21:13:35 2022 +0800

    style(RocketMQBinaryMessageReader.java): Lambda can be replaced with call qualifier
    
    #1980
---
 .../connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java b/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
index 07888a6a..c210370c 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
@@ -56,7 +56,7 @@ public class RocketMQBinaryMessageReader
 
     @Override
     protected void forEachHeader(BiConsumer<String, String> fn) {
-        this.headers.forEach((k, v) -> fn.accept(k, v));
+        this.headers.forEach(fn);
     }
 
     @Override


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org