From 3b33a5721879e2468745af4136f437356517b1f9 Mon Sep 17 00:00:00 2001 From: AKurakin Date: Tue, 23 May 2023 18:56:17 +0300 Subject: [PATCH] =?UTF-8?q?platform-messaging=20QueueConsumer=20=D1=83?= =?UTF-8?q?=D1=82=D0=BE=D1=87=D0=BD=D0=B8=D0=BB=20stacktrace=20=D0=B2=20?= =?UTF-8?q?=D0=BB=D0=BE=D0=B3=D0=B5=20=D0=BF=D1=80=D0=B8=20=D0=B2=D1=8B?= =?UTF-8?q?=D0=B7=D0=BE=D0=B2=D0=B5=20Init.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../clearing/platform/messaging/service/QueueConsumer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 7b44ad544..f67824a6d 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 @@ -75,6 +75,7 @@ public class QueueConsumer implements AutoCloseable { } public void init() { + final Exception debugCallerStacktrace = new Exception("init call"); inputExecutor.submit(() -> { try { log.debug("Using kafka consumer {} for subscribe on \"{}\"", consumer, callbacks.keySet()); @@ -128,7 +129,8 @@ public class QueueConsumer implements AutoCloseable { } catch (WakeupException e) { if (!closed.get()) throw e; } catch (Throwable e) { - log.error(ExceptionUtils.getStackTrace(e)); + log.error("QueueConsumer error: {}; main thread stacktrace: {}", + ExceptionUtils.getStackTrace(e), ExceptionUtils.getStackTrace(debugCallerStacktrace)); } finally { consumer.close(); }