diff --git a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/config/PlannerQueueConfig.java b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/config/PlannerQueueConfig.java index f7b76882c..30ba350ee 100644 --- a/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/config/PlannerQueueConfig.java +++ b/clearing-parent/scheduler-service/src/main/java/ru/spcex/clearing/scheduler/config/PlannerQueueConfig.java @@ -10,6 +10,7 @@ import ru.spcex.platform.utils.log.ExceptionUtils; import javax.validation.constraints.NotNull; import java.util.Map; +import java.util.Objects; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; @@ -26,6 +27,8 @@ public class PlannerQueueConfig { public static void addToPlannerQueue(@NotNull TaskManager.Process process, @NotNull PlannerAllToday plannerAllToday) { try { + Objects.requireNonNull(process); + Objects.requireNonNull(plannerAllToday); plannerQueue.put(Map.entry(process, plannerAllToday)); } catch (InterruptedException e) { log.warn("InterruptedException plannerQueue.put {}", ExceptionUtils.getStackTrace(e));