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/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 7e7e11b49 Fixed issue #3090
new d18ca5015 Merge pull request #3110 from piyush280599/patch-3
7e7e11b49 is described below
commit 7e7e11b49844c1f78e940935c8e995ca8199a224
Author: Piyush <[email protected]>
AuthorDate: Fri Feb 10 15:21:28 2023 +0530
Fixed issue #3090
---
.../core/protocol/tcp/client/session/retry/RetryContext.java | 9 ++-------
1 file changed, 2 insertions(+), 7 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/RetryContext.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/RetryContext.java
index 9a5359ee0..4671e1b20 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/RetryContext.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/RetryContext.java
@@ -40,13 +40,8 @@ public abstract class RetryContext implements Delayed {
@Override
public int compareTo(Delayed delayed) {
RetryContext obj = (RetryContext) delayed;
- if (this.executeTime > obj.executeTime) {
- return 1;
- } else if (this.executeTime == obj.executeTime) {
- return 0;
- } else {
- return -1;
- }
+ return Long.compare(this.executeTime, obj.executeTime);
+
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
