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 63b91052d [ISSUE #2987] Boxed sendBackTimes to prevent
NullPointerException (#2987)
new 27760ad91 Merge pull request #2995 from kanha-gupta/eventmesh-2987
63b91052d is described below
commit 63b91052d849d4bc85ae3d57983851ebea7c3a4b
Author: Kanha gupta <[email protected]>
AuthorDate: Thu Feb 2 17:00:44 2023 +0530
[ISSUE #2987] Boxed sendBackTimes to prevent NullPointerException (#2987)
---
.../runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
index 894759f71..245cf311e 100644
---
a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
+++
b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
@@ -486,7 +486,7 @@ public class ClientGroupWrapper {
group, topic, bizSeqNo, sendBackTimes,
sendBackFromEventMeshIp);
- if (sendBackTimes >= eventMeshTCPServer
+ if (Objects.requireNonNull(sendBackTimes) >=
eventMeshTCPServer
.getEventMeshTCPConfiguration().eventMeshTcpSendBackMaxTimes) {
log.error(
"sendBack to broker over max times:{},
groupName:{}, topic:{}, "
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
