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 b4feffcf5 [ISSUE #4456] startup failure caused by Retryer
b4feffcf5 is described below
commit b4feffcf5c6dcb94cee447c4c7534985cfd1912c
Author: pandaapo <[email protected]>
AuthorDate: Mon Sep 25 14:23:24 2023 +0800
[ISSUE #4456] startup failure caused by Retryer
---
.../org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java | 2 +-
.../apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java | 2 +-
.../apache/eventmesh/runtime/core/protocol/http/retry/HttpRetryer.java | 2 +-
.../core/protocol/tcp/client/session/retry/EventMeshTcpRetryer.java | 2 +-
4 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java
index 3bfa13f87..5b0a64e71 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/AbstractRetryer.java
@@ -39,7 +39,7 @@ public abstract class AbstractRetryer {
return retrys.size();
}
- protected void initDispatcher(Thread dispatcher) {
+ protected void initDispatcher() {
dispatcher = new Thread(() -> {
try {
DelayRetryable retryObj;
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java
index b3f209448..cb10a9054 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java
@@ -56,7 +56,7 @@ public class GrpcRetryer extends AbstractRetryer {
new EventMeshThreadFactory("grpc-retry", true,
Thread.NORM_PRIORITY),
new ThreadPoolExecutor.AbortPolicy());
- initDispatcher(dispatcher);
+ initDispatcher();
}
}
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/retry/HttpRetryer.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/retry/HttpRetryer.java
index 891d09901..4a672d652 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/retry/HttpRetryer.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/retry/HttpRetryer.java
@@ -62,7 +62,7 @@ public class HttpRetryer extends AbstractRetryer {
new EventMeshThreadFactory("http-retry", true,
Thread.NORM_PRIORITY),
new ThreadPoolExecutor.AbortPolicy());
- initDispatcher(dispatcher);
+ initDispatcher();
}
}
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/EventMeshTcpRetryer.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/EventMeshTcpRetryer.java
index bacfdd71b..3b9702375 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/EventMeshTcpRetryer.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/EventMeshTcpRetryer.java
@@ -89,7 +89,7 @@ public class EventMeshTcpRetryer extends AbstractRetryer {
@Override
public void init() {
- initDispatcher(dispatcher);
+ initDispatcher();
}
public void printRetryThreadPoolState() {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
