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/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 6fbfd7acb [ISSUE #3909] Replaced anonymous new ChannelFutureListener()
with lambda (#3923)
6fbfd7acb is described below
commit 6fbfd7acbf228ae8fed678875ac19cbadd902b11
Author: Kirill Saied <[email protected]>
AuthorDate: Wed May 31 05:31:12 2023 +0200
[ISSUE #3909] Replaced anonymous new ChannelFutureListener() with lambda
(#3923)
* [ISSUE #3909] Replaced anonymous new ChannelFutureListener() with lambda
* Fixed checkstyle for source-connector-rocketmq
* Fixed checkstyle for eventmesh-storage-rocketmq
---
.../source/connector/rocketmq/RocketMQSourceWorker.java | 4 ++--
.../core/protocol/tcp/client/task/MessageTransferTask.java | 9 +--------
2 files changed, 3 insertions(+), 10 deletions(-)
diff --git
a/eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/RocketMQSourceWorker.java
b/eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/RocketMQSourceWorker.java
index 9adc738a0..41ce3135a 100644
---
a/eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/RocketMQSourceWorker.java
+++
b/eventmesh-connectors/source-connector-rocketmq/src/main/java/org/apache/eventmesh/source/connector/rocketmq/RocketMQSourceWorker.java
@@ -23,9 +23,9 @@ import
org.apache.eventmesh.source.connector.rocketmq.connector.RocketMQSourceCo
public class RocketMQSourceWorker {
public static void main(String[] args) throws Exception {
-
+
Application.run(RocketMQSourceConnector.class);
-
+
}
}
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java
index 8d00a9998..62a97dc3f 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java
@@ -54,7 +54,6 @@ import org.slf4j.LoggerFactory;
import io.cloudevents.CloudEvent;
import io.cloudevents.core.builder.CloudEventBuilder;
-import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.opentelemetry.api.trace.Span;
@@ -134,13 +133,7 @@ public class MessageTransferTask extends AbstractTask {
msg.setHeader(new Header(replyCmd, OPStatus.FAIL.getCode(),
"Tps overload, global flow control", pkg.getHeader().getSeq()));
ctx.writeAndFlush(msg).addListener(
- new ChannelFutureListener() {
- @Override
- public void operationComplete(ChannelFuture future)
throws Exception {
- Utils.logSucceedMessageFlow(msg,
session.getClient(), startTime,
- taskExecuteTime);
- }
- }
+ (ChannelFutureListener) future ->
Utils.logSucceedMessageFlow(msg, session.getClient(), startTime,
taskExecuteTime)
);
TraceUtils.finishSpanWithException(ctx, event, "Tps overload,
global flow control", null);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
