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
<[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
