feature(forest): 新增队列查询接口

service-forest/pom.xml

@@ -17,6 +17,11 @@
             <artifactId>service-configuration</artifactId>
             <version>1.0.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.lanyuanxiaoyao.micro.service</groupId>
+            <artifactId>entity</artifactId>
+            <version>1.0.0</version>
+        </dependency>
         <dependency>
             <groupId>com.dtflys.forest</groupId>
             <artifactId>forest-spring-boot-starter</artifactId>

service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/DequeService.java

@@ -0,0 +1,22 @@
+package com.lanyuanxiaoyao.service.forest.service;
+
+import com.dtflys.forest.annotation.BaseRequest;
+import com.dtflys.forest.annotation.Get;
+import com.eshore.odcp.hudi.connector.entity.compaction.ScheduleJob;
+import com.lanyuanxiaoyao.micro.service.entity.queue.QueueItem;
+import org.eclipse.collections.api.list.ImmutableList;
+
+/**
+ * 队列查询
+ *
+ * @author lanyuanxiaoyao
+ * @date 2023-05-07
+ */
+@BaseRequest(baseURL = "http://queue/deque")
+public interface DequeService {
+    @Get("/names")
+    ImmutableList<String> names();
+
+    @Get("/all/{name}")
+    ImmutableList<QueueItem<ScheduleJob>> all(String name);
+}

service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/QueueService.java

@@ -0,0 +1,22 @@
+package com.lanyuanxiaoyao.service.forest.service;
+
+import com.dtflys.forest.annotation.BaseRequest;
+import com.dtflys.forest.annotation.Get;
+import com.eshore.odcp.hudi.connector.entity.compaction.ScheduleJob;
+import com.lanyuanxiaoyao.micro.service.entity.queue.QueueItem;
+import org.eclipse.collections.api.list.ImmutableList;
+
+/**
+ * 队列查询
+ *
+ * @author lanyuanxiaoyao
+ * @date 2023-05-07
+ */
+@BaseRequest(baseURL = "http://queue/queue")
+public interface QueueService {
+    @Get("/names")
+    ImmutableList<String> names();
+
+    @Get("/all/{name}")
+    ImmutableList<QueueItem<ScheduleJob>> all(String name);
+}