openapi添加消费者监控 (#307)

* broker管理接口修改 * openapi添加消费者监控 * openapi添加消费者监控
jd-opensource · Sep 22, 2020 · 002ad5b · 002ad5b
1 parent 0331c9e
commit 002ad5b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/...ue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/Impl/OpenAPIServiceImpl.java b/...ue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/Impl/OpenAPIServiceImpl.java
@@ -495,6 +495,11 @@ public List<ApplicationToken> tokens(String app) {
 
     }
 
+    @Override
+    public BrokerMonitorRecord brokerMonitor(Subscribe subscribe) {
+        return brokerMonitorService.find(subscribe, true);
+    }
+
     /**
      *
      *  Check the subscription legal or not

diff --git a/...le/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/OpenAPIService.java b/...le/joyqueue-data/joyqueue-data-service/src/main/java/org/joyqueue/api/OpenAPIService.java
@@ -201,5 +201,7 @@ public interface OpenAPIService {
      **/
     List<ApplicationToken> tokens(String app);
 
+    BrokerMonitorRecord brokerMonitor(Subscribe subscribe);
+
 
 }
-Original file line number
+Diff line change
@@ Expand Up / @@ -201,5 +201,7 @@ public interface OpenAPIService { @@
          **/
         List<ApplicationToken> tokens(String app);
+        BrokerMonitorRecord brokerMonitor(Subscribe subscribe);
     }