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 index 5bf2a47..982fe7c 100644 --- 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 @@ -2,6 +2,7 @@ package com.lanyuanxiaoyao.service.forest.service; import com.dtflys.forest.annotation.BaseRequest; import com.dtflys.forest.annotation.Get; +import com.dtflys.forest.annotation.Var; import com.eshore.odcp.hudi.connector.entity.compaction.ScheduleJob; import com.lanyuanxiaoyao.micro.service.entity.queue.QueueItem; import org.eclipse.collections.api.list.ImmutableList; @@ -18,5 +19,5 @@ public interface DequeService { ImmutableList names(); @Get("/all/{name}") - ImmutableList> all(String name); + ImmutableList> all(@Var("name") 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 index f22bac2..edff9aa 100644 --- 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 @@ -2,6 +2,7 @@ package com.lanyuanxiaoyao.service.forest.service; import com.dtflys.forest.annotation.BaseRequest; import com.dtflys.forest.annotation.Get; +import com.dtflys.forest.annotation.Var; import com.eshore.odcp.hudi.connector.entity.compaction.ScheduleJob; import com.lanyuanxiaoyao.micro.service.entity.queue.QueueItem; import org.eclipse.collections.api.list.ImmutableList; @@ -18,5 +19,5 @@ public interface QueueService { ImmutableList names(); @Get("/all/{name}") - ImmutableList> all(String name); + ImmutableList> all(@Var("name") String name); }