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/06 03:02:37 UTC

[incubator-eventmesh] branch master updated: [ISSUE #2987] Boxed sendBackTimes to prevent NullPointerException (#2987)

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 <ka...@gmail.com>
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: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org