Update EventMeshHttpConsumer.java

apache · Mar 3, 2023 · 3939f92 · 3939f92
1 parent 8e5e460
commit 3939f92
Showing 1 changed file with 6 additions and 6 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 (Object.requireNonNull(ret).getRetCode() != EventMeshRetCode.SUCCESS.getRetCode()) {
- throw new EventMeshException(ret.getRetCode(),ret.getRetMsg());
+ if (Objects.requireNonNull(ret).getRetCode() != EventMeshRetCode.SUCCESS.getRetCode()) {
+ throw new EventMeshException(ret.getRetCode(), ret.getRetMsg());
  }
  SUBSCRIPTIONS.addAll(topicList);
  } catch (Exception ex) {
@@ -129,8 +129,8 @@ public void heartBeat(final List<SubscriptionItem> topicList, final String subsc
  final String target = selectEventMesh();
  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(ret.getRetCode(),ret.getRetMsg());
+ if (EventMeshRetCode.SUCCESS.getRetCode() != Objects.requireNonNull(ret).getRetCode()) {
+ throw new EventMeshException(ret.getRetCode(), ret.getRetMsg());
  }
  } catch (Exception e) {
  log.error("send heartBeat error", e);
@@ -157,8 +157,8 @@ public void unsubscribe(final List<String> topicList, final String unSubscribeUr
  final String unSubRes = HttpUtils.post(httpClient, target, unSubscribeParam);
  final EventMeshRetObj ret = JsonUtils.parseObject(unSubRes, EventMeshRetObj.class);
 
- if (EventMeshRetCode.SUCCESS.getRetCode() != Object.requireNonNull(ret).getRetCode()) {
- throw new EventMeshException(ret.getRetCode(),ret.getRetMsg());
+ if (EventMeshRetCode.SUCCESS.getRetCode() != Objects.requireNonNull(ret).getRetCode()) {
+ throw new EventMeshException(ret.getRetCode(), ret.getRetMsg());
  }
  // todo: avoid concurrentModifiedException
  SUBSCRIPTIONS.removeIf(item -> topicList.contains(item.getTopic()));