This is an automated email from the ASF dual-hosted git repository.
mxsm 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 0b6ae9f11 [ISSUE #4549]Remove unnecessary transient modifiers. (#4550)
0b6ae9f11 is described below
commit 0b6ae9f115f3cc7aec86cc591ed50f1036531952
Author: yanrongzhen <[email protected]>
AuthorDate: Tue Nov 7 17:50:54 2023 +0800
[ISSUE #4549]Remove unnecessary transient modifiers. (#4550)
---
.../eventmesh/runtime/core/protocol/http/push/HTTPMessageHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPMessageHandler.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPMessageHandler.java
index 789b2e4c7..68ad9c596 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPMessageHandler.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/HTTPMessageHandler.java
@@ -46,12 +46,12 @@ public class HTTPMessageHandler implements MessageHandler {
private final transient EventMeshConsumer eventMeshConsumer;
- private static final transient ScheduledExecutorService SCHEDULER =
+ private static final ScheduledExecutorService SCHEDULER =
ThreadPoolFactory.createSingleScheduledExecutor("eventMesh-pushMsgTimeout");
private static final Integer CONSUMER_GROUP_WAITING_REQUEST_THRESHOLD =
10000;
- protected static final transient Map<String, Set<AbstractHTTPPushRequest>>
waitingRequests = Maps.newConcurrentMap();
+ protected static final Map<String, Set<AbstractHTTPPushRequest>>
waitingRequests = Maps.newConcurrentMap();
private final transient ThreadPoolExecutor pushExecutor;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
