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 dadd5ed97 fix 2970 NPE
new d62980eba Merge pull request #3063 from zhaoyansheng163/issue2970
dadd5ed97 is described below
commit dadd5ed9737591f63907890775a7c66e5ac8612d
Author: zhaoyansheng163 <[email protected]>
AuthorDate: Tue Feb 7 18:31:10 2023 +0800
fix 2970 NPE
---
.../org/apache/eventmesh/client/http/AbstractProducerHttpClient.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/AbstractProducerHttpClient.java
b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/AbstractProducerHttpClient.java
index ef30436da..e3e4a5730 100644
---
a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/AbstractProducerHttpClient.java
+++
b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/AbstractProducerHttpClient.java
@@ -28,6 +28,7 @@ import
org.apache.eventmesh.common.protocol.http.common.EventMeshRetCode;
import org.apache.eventmesh.common.utils.JsonUtils;
import java.io.IOException;
+import java.util.Objects;
/**
* AbstractProducerHttpClient
@@ -48,7 +49,7 @@ public abstract class AbstractProducerHttpClient<T> extends
AbstractHttpClient i
try {
final String response = HttpUtils.post(httpClient, target,
builderPublishRequestParam(t));
final EventMeshRetObj ret = JsonUtils.deserialize(response,
EventMeshRetObj.class);
- if (ret.getRetCode() != EventMeshRetCode.SUCCESS.getRetCode()) {
+ if (Objects.requireNonNull(ret).getRetCode() !=
EventMeshRetCode.SUCCESS.getRetCode()) {
throw new EventMeshException(ret.getRetCode(),
ret.getRetMsg());
}
} catch (Exception exception) {
@@ -63,7 +64,7 @@ public abstract class AbstractProducerHttpClient<T> extends
AbstractHttpClient i
try {
final String response = HttpUtils.post(httpClient, target,
builderRequestParam(message, timeout));
final EventMeshRetObj ret = JsonUtils.deserialize(response,
EventMeshRetObj.class);
- if (ret.getRetCode() == EventMeshRetCode.SUCCESS.getRetCode()) {
+ if (Objects.requireNonNull(ret).getRetCode() ==
EventMeshRetCode.SUCCESS.getRetCode()) {
return transformMessage(ret);
}
throw new EventMeshException(ret.getRetCode(), ret.getRetMsg());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
