platform-messaging debug log++

This commit is contained in:
AKurakin 2023-05-31 20:28:15 +03:00
parent 86b9bd095f
commit 5c3cc9265e

View file

@ -112,6 +112,9 @@ public class QueueConsumer implements AutoCloseable {
} catch (Throwable e) {
log.error("Listener {} last topic \"{}\", error: {}",
QueueConsumer.this.getClass().getName(), lastTopic, ExceptionUtils.getStackTrace(e));
if (lastTopic == null) {
log.debug("main thread stacktrace: {}", ExceptionUtils.getStackTrace(debugCallerStacktrace));
}
if (producer != null && o != null) {
sendErrorResponse((BaseRequest<?>) o, correlationId);
}