From 39a5101af3aac6759f911137e6aa29cd61ab8b9e Mon Sep 17 00:00:00 2001
From: lanyuanxiaoyao <lanyuanxiaoyao@gmail.com>
Date: Sun, 7 May 2023 16:18:32 +0800
Subject: [PATCH] =?UTF-8?q?feature(forest):=20=E6=96=B0=E5=A2=9E=E9=98=9F?=
 =?UTF-8?q?=E5=88=97=E6=9F=A5=E8=AF=A2=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 service-forest/pom.xml                        |  5 +++++
 .../service/forest/service/DequeService.java  | 22 +++++++++++++++++++
 .../service/forest/service/QueueService.java  | 22 +++++++++++++++++++
 3 files changed, 49 insertions(+)
 create mode 100644 service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/DequeService.java
 create mode 100644 service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/QueueService.java

diff --git a/service-forest/pom.xml b/service-forest/pom.xml
index 84eb000..efe6783 100644
--- a/service-forest/pom.xml
+++ b/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>
diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/DequeService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/DequeService.java
new file mode 100644
index 0000000..5bf2a47
--- /dev/null
+++ b/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);
+}
diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/QueueService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/QueueService.java
new file mode 100644
index 0000000..f22bac2
--- /dev/null
+++ b/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);
+}