This is an automated email from the ASF dual-hosted git repository.
mytang0 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 c5103ef75 Fixex #3417
new 99ab26232 Merge pull request #3460 from erzohrakhan/fix_3417
c5103ef75 is described below
commit c5103ef75b25e3e6cd931daaef0b3294dc0cc89e
Author: Zohra Khan <[email protected]>
AuthorDate: Thu Mar 16 20:55:23 2023 +0530
Fixex #3417
---
.../runtime/core/protocol/http/processor/HeartBeatProcessor.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java
index 550e08053..888e7a1c3 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/HeartBeatProcessor.java
@@ -179,9 +179,7 @@ public class HeartBeatProcessor implements
HttpRequestProcessor {
final long startTime = System.currentTimeMillis();
try {
- final CompleteHandler<HttpCommand> handler = new
CompleteHandler<HttpCommand>() {
- @Override
- public void onResponse(final HttpCommand httpCommand) {
+ final CompleteHandler<HttpCommand> handler = httpCommand -> {
try {
if (log.isDebugEnabled()) {
log.debug("{}", httpCommand);
@@ -192,7 +190,6 @@ public class HeartBeatProcessor implements
HttpRequestProcessor {
} catch (Exception ex) {
//ignore
}
- }
};
responseEventMeshCommand =
asyncContext.getRequest().createHttpCommandResponse(EventMeshRetCode.SUCCESS);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
