You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2023/02/12 13:25:07 UTC
[incubator-eventmesh] branch master updated: Fixed issue #3090
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 <11...@users.noreply.github.com>
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: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org