treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

platform-messaging QueueConsumer уточнил stacktrace в логе при вызове Init.

Browse source
This commit is contained in:
AKurakin 2023-05-23 18:56:17 +03:00
parent c2f463a1a7
commit 3b33a57218
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java
View file

@ -75,6 +75,7 @@ public class QueueConsumer implements AutoCloseable {
} }
public void init() { public void init() {
final Exception debugCallerStacktrace = new Exception("init call");
inputExecutor.submit(() -> { inputExecutor.submit(() -> {
try { try {
log.debug("Using kafka consumer {} for subscribe on \"{}\"", consumer, callbacks.keySet()); log.debug("Using kafka consumer {} for subscribe on \"{}\"", consumer, callbacks.keySet());
@ -128,7 +129,8 @@ public class QueueConsumer implements AutoCloseable {
} catch (WakeupException e) { } catch (WakeupException e) {
if (!closed.get()) throw e; if (!closed.get()) throw e;
} catch (Throwable e) { } catch (Throwable e) {
log.error(ExceptionUtils.getStackTrace(e)); log.error("QueueConsumer error: {}; main thread stacktrace: {}",
ExceptionUtils.getStackTrace(e), ExceptionUtils.getStackTrace(debugCallerStacktrace));
} finally { } finally {
consumer.close(); consumer.close();
} }