Merge pull request #4 from piyush280599/piyush280599-patch-4

Update EventMeshHttpConsumer.java
xwm1992 · Feb 27, 2023 · 8e5e460 · 8e5e460
2 parents dad245d + 3faec22
commit 8e5e460
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...k-java/src/main/java/org/apache/eventmesh/client/http/consumer/EventMeshHttpConsumer.java b/...k-java/src/main/java/org/apache/eventmesh/client/http/consumer/EventMeshHttpConsumer.java
@@ -98,8 +98,8 @@ public void subscribe(final List<SubscriptionItem> topicList, final String subsc
         try {
             final String subRes = HttpUtils.post(httpClient, target, subscribeParam);
             final EventMeshRetObj ret = JsonUtils.parseObject(subRes, EventMeshRetObj.class);
-            if (ret.getRetCode() != EventMeshRetCode.SUCCESS.getRetCode()) {
-                throw new EventMeshException(Object.requireNonNull(ret).getRetCode(), Object.requireNonNull(ret).getRetMsg());
+            if (Object.requireNonNull(ret).getRetCode() != EventMeshRetCode.SUCCESS.getRetCode()) {
+                throw new EventMeshException(ret.getRetCode(),ret.getRetMsg());
             }
             SUBSCRIPTIONS.addAll(topicList);
         } catch (Exception ex) {
@@ -130,7 +130,7 @@ public void heartBeat(final List<SubscriptionItem> topicList, final String subsc
                 final String res = HttpUtils.post(httpClient, target, requestParam);
                 final EventMeshRetObj ret = JsonUtils.parseObject(res, EventMeshRetObj.class);
                 if (EventMeshRetCode.SUCCESS.getRetCode() != Object.requireNonNull(ret).getRetCode()) {
-                    throw new EventMeshException(Object.requireNonNull(ret).getRetCode(), Object.requireNonNull(ret).getRetMsg());
+                    throw new EventMeshException(ret.getRetCode(),ret.getRetMsg());
                 }
             } catch (Exception e) {
                 log.error("send heartBeat error", e);
@@ -158,7 +158,7 @@ public void unsubscribe(final List<String> topicList, final String unSubscribeUr
             final EventMeshRetObj ret = JsonUtils.parseObject(unSubRes, EventMeshRetObj.class);
 
             if (EventMeshRetCode.SUCCESS.getRetCode() != Object.requireNonNull(ret).getRetCode()) {
-                throw new EventMeshException(Object.requireNonNull(ret).getRetCode(), Object.requireNonNull (ret).getRetMsg());
+                throw new EventMeshException(ret.getRetCode(),ret.getRetMsg());
             }
             // todo: avoid concurrentModifiedException
             SUBSCRIPTIONS.removeIf(item -> topicList.contains(item.getTopic()));