lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(forest): 修复参数未生效

Browse Source
This commit is contained in:
兰缘小妖
2023-05-07 16:58:50 +08:00
parent 39a5101af3
commit 494c8e7412
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/DequeService.java
View File

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

3
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/QueueService.java
View File

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