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);
+}