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 a62333b4d [ISSUE #4022]contains() is a legacy method that is
equivalent to containsValue() (#4249)
a62333b4d is described below
commit a62333b4db6a86aa0e3252f7a930e26e02576298
Author: Harshitha Sudhakar
<[email protected]>
AuthorDate: Thu Jul 20 06:51:08 2023 +0530
[ISSUE #4022]contains() is a legacy method that is equivalent to
containsValue() (#4249)
* Update TcpClient.java
* Update HeatBeatScheduler.java
---
.../org/apache/eventmesh/registry/consul/service/HeatBeatScheduler.java | 2 +-
.../src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry/consul/service/HeatBeatScheduler.java
b/eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry/consul/service/HeatBeatScheduler.java
index a62db12fd..d08a0f375 100644
---
a/eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry/consul/service/HeatBeatScheduler.java
+++
b/eventmesh-registry-plugin/eventmesh-registry-consul/src/main/java/org/apache/eventmesh/registry/consul/service/HeatBeatScheduler.java
@@ -91,7 +91,7 @@ public class HeatBeatScheduler {
consulClient.agentCheckPass(checkId, aclToken);
return;
}
- if (heartBeatMap.contains(instance)) {
+ if (heartBeatMap.containsValue(instance)) {
consulClient.agentCheckPass(checkId);
}
} finally {
diff --git
a/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java
b/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java
index d904d55fb..9cc206a7a 100644
---
a/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java
+++
b/eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/TcpClient.java
@@ -187,7 +187,7 @@ public abstract class TcpClient implements Closeable {
protected Package io(Package msg, long timeout) throws Exception {
Object key = RequestContext.key(msg);
RequestContext context = RequestContext.context(key, msg);
- if (!contexts.contains(context)) {
+ if (!contexts.containsValue(context)) {
contexts.put(key, context);
} else {
if (log.isInfoEnabled()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
