You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by we...@apache.org on 2023/04/18 07:55:57 UTC
[eventmesh] branch master updated: Update HeartBeatProcessor.java
This is an automated email from the ASF dual-hosted git repository.
weihu 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 b68df811d Update HeartBeatProcessor.java
new 203290601 Merge pull request #3741 from harshithasudhakar/patch-21
b68df811d is described below
commit b68df811d886701f49a571f59f0fa07403d064d6
Author: Harshitha Sudhakar <11...@users.noreply.github.com>
AuthorDate: Sat Apr 15 23:07:32 2023 +0530
Update HeartBeatProcessor.java
Reduced the total number of continue statements used in lines 125, 152
---
.../runtime/core/protocol/http/processor/HeartBeatProcessor.java | 6 +-----
1 file changed, 1 insertion(+), 5 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 fe0d5d733..893b4192d 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
@@ -122,7 +122,7 @@ public class HeartBeatProcessor implements HttpRequestProcessor {
client.setUrl(heartbeatEntity.url);
client.setLastUpTime(new Date());
- if (StringUtils.isBlank(client.getTopic())) {
+ if (StringUtils.isBlank(client.getTopic()) || StringUtils.isBlank(client.getUrl())) {
continue;
}
@@ -149,10 +149,6 @@ public class HeartBeatProcessor implements HttpRequestProcessor {
}
}
- if (StringUtils.isBlank(client.getUrl())) {
- continue;
- }
-
final String groupTopicKey = client.getConsumerGroup() + "@" + client.getTopic();
List<Client> clients = tmpMap.computeIfAbsent(groupTopicKey, k -> new ArrayList<>());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org