fix emitter error
This commit is contained in:
@@ -3,11 +3,14 @@ package de.infinimotion.backend.task;
|
|||||||
import de.infinimotion.model.backend.*;
|
import de.infinimotion.model.backend.*;
|
||||||
import io.quarkus.scheduler.Scheduled;
|
import io.quarkus.scheduler.Scheduled;
|
||||||
import jakarta.enterprise.context.ApplicationScoped;
|
import jakarta.enterprise.context.ApplicationScoped;
|
||||||
|
import jakarta.enterprise.inject.Instance;
|
||||||
import jakarta.inject.Inject;
|
import jakarta.inject.Inject;
|
||||||
|
import jakarta.ws.rs.core.Request;
|
||||||
|
|
||||||
import java.time.LocalDate;
|
import java.time.LocalDate;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
@ApplicationScoped
|
@ApplicationScoped
|
||||||
public class ShowPlanner {
|
public class ShowPlanner {
|
||||||
@@ -15,7 +18,7 @@ public class ShowPlanner {
|
|||||||
@Inject
|
@Inject
|
||||||
RequestReply requester;
|
RequestReply requester;
|
||||||
|
|
||||||
@Scheduled(every = "1h")
|
@Scheduled(every = "1h", delay = 10, delayUnit = TimeUnit.SECONDS)
|
||||||
void planShows() throws Exception {
|
void planShows() throws Exception {
|
||||||
CommandWrapper requestPlans = new CommandListPlan().serialize().generateIds();
|
CommandWrapper requestPlans = new CommandListPlan().serialize().generateIds();
|
||||||
List<Plan> plans = CommandListPlanResponse.deserialize(requester.request(requestPlans)).getList();
|
List<Plan> plans = CommandListPlanResponse.deserialize(requester.request(requestPlans)).getList();
|
||||||
|
|||||||
Reference in New Issue
Block a user