From fe3cc5f6f53e3a02a9fdb2cbf35fbf499ae21011 Mon Sep 17 00:00:00 2001
From: psemenkov <psemenkov@mfd.ru>
Date: Wed, 26 Apr 2023 11:03:07 +0300
Subject: [PATCH] =?UTF-8?q?http://jira.mfd.msk:8088/browse/CLS-268=20?=
 =?UTF-8?q?=D0=A1=D0=B4=D0=B5=D0=BB=D0=B0=D0=BB=20=D0=BF=D1=80=D0=BE=D0=B2?=
 =?UTF-8?q?=D0=B5=D1=80=D0=BA=D1=83=20=D0=BD=D0=B0=20Null.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ru/spcex/clearing/scheduler/config/PlannerQueueConfig.java | 3 +++
 1 file changed, 3 insertions(+)

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