This is an automated email from the ASF dual-hosted git repository.
jonyang 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 cebef0742 [ISSUE #3103] collapase Exception (#3133)
cebef0742 is described below
commit cebef074286d88595326d280e5fd8c8e0243e5e0
Author: dingrui <[email protected]>
AuthorDate: Wed Feb 15 22:01:14 2023 +0800
[ISSUE #3103] collapase Exception (#3133)
---
.../runtime/core/protocol/http/push/AsyncHTTPPushRequest.java | 11 ++---------
1 file changed, 2 insertions(+), 9 deletions(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AsyncHTTPPushRequest.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AsyncHTTPPushRequest.java
index 60b6d9685..775da0b46 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AsyncHTTPPushRequest.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/push/AsyncHTTPPushRequest.java
@@ -83,7 +83,7 @@ public class AsyncHTTPPushRequest extends
AbstractHTTPPushRequest {
private Map<String, Set<AbstractHTTPPushRequest>> waitingRequests;
public AsyncHTTPPushRequest(HandleMsgContext handleMsgContext,
- Map<String, Set<AbstractHTTPPushRequest>>
waitingRequests) {
+ Map<String, Set<AbstractHTTPPushRequest>> waitingRequests) {
super(handleMsgContext);
this.waitingRequests = waitingRequests;
}
@@ -189,7 +189,6 @@ public class AsyncHTTPPushRequest extends
AbstractHTTPPushRequest {
eventMeshHttpConfiguration.getEventMeshWebhookOrigin(),
urlAuthType);
-
eventMeshHTTPServer.getMetrics().getSummaryMetrics().recordPushMsg();
this.lastPushTime = System.currentTimeMillis();
@@ -350,13 +349,7 @@ public class AsyncHTTPPushRequest extends
AbstractHTTPPushRequest {
handleMsgContext.getBizSeqNo(),
handleMsgContext.getUniqueId(), content);
}
return ClientRetCode.FAIL;
- } catch (JsonException e) {
- if (MESSAGE_LOGGER.isWarnEnabled()) {
- MESSAGE_LOGGER.warn("url:{}, bizSeqno:{}, uniqueId:{},
httpResponse:{}", currPushUrl,
- handleMsgContext.getBizSeqNo(),
handleMsgContext.getUniqueId(), content);
- }
- return ClientRetCode.FAIL;
- } catch (Throwable t) {
+ } catch (Throwable e) {
if (MESSAGE_LOGGER.isWarnEnabled()) {
MESSAGE_LOGGER.warn("url:{}, bizSeqno:{}, uniqueId:{},
httpResponse:{}", currPushUrl,
handleMsgContext.getBizSeqNo(),
handleMsgContext.getUniqueId(), content);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
