From 6ad470b67f89816df03a78b3d278ccd5fc717116 Mon Sep 17 00:00:00 2001
From: ialbert <ialbert@mfd.ru>
Date: Fri, 12 Aug 2022 15:24:56 +0300
Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-16

---
 .gitignore                                                  | 1 +
 .../controller/request/cud/MoneyMarketCreateAction.java     | 1 +
 .../clearing/platform/messaging/service/QueueConsumer.java  | 6 +++++-
 3 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/.gitignore b/.gitignore
index f60675edf..46b4063fb 100644
--- a/.gitignore
+++ b/.gitignore
@@ -2,3 +2,4 @@ target
 /.idea/
 *.iml
 logs
+tmp_notes.**
diff --git a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/MoneyMarketCreateAction.java b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/MoneyMarketCreateAction.java
index 0e13f40d0..b3e07af27 100644
--- a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/MoneyMarketCreateAction.java
+++ b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/controller/request/cud/MoneyMarketCreateAction.java
@@ -11,6 +11,7 @@ public class MoneyMarketCreateAction implements IAction<MoneyMarketCreateRequest
     @JsonFormat(pattern = "yyyy-MM-dd", timezone = "Europe/Moscow")
     @JsonProperty
     public Instant startDate;
+    @JsonFormat(pattern = "yyyy-MM-dd", timezone = "Europe/Moscow")
     @JsonProperty
     public Instant endDate;
     @JsonProperty
diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
index d0859328e..f8643da44 100644
--- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
+++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
@@ -5,8 +5,11 @@ import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.apache.kafka.common.errors.WakeupException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import ru.spcex.clearing.platform.messaging.logic.functional.BuilderConsumerStep;
 import ru.spcex.clearing.platform.messaging.logic.functional.ConsumerSpecificClass;
+import ru.spcex.platform.utils.log.ExceptionUtils;
 
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
@@ -17,6 +20,7 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 public class QueueConsumer implements AutoCloseable {
+    private final Logger log = LoggerFactory.getLogger(getClass());
     private final AtomicBoolean closed = new AtomicBoolean(false);
     private final Consumer<String, Object> consumer;
     private final ExecutorService executor;
@@ -45,7 +49,7 @@ public class QueueConsumer implements AutoCloseable {
             } catch (WakeupException e) {
                 if (!closed.get()) throw e;
             } catch (Throwable e) {
-                throw new RuntimeException(e);
+                log.error(ExceptionUtils.getStackTrace(e));
             } finally {
                 consumer.close();
             }