Include the name of the calling thread when a command times out.

This commit is contained in:
Jon Chambers 2020-11-11 12:38:17 -05:00 committed by Jon Chambers
parent 325e65db7f
commit fb9aa672c9
2 changed files with 2 additions and 2 deletions

View File

@ -97,7 +97,7 @@ public class FaultTolerantPubSubConnection<K, V> {
private void recordCommandTimeout(final RedisCommandTimeoutException e) {
commandTimeoutMeter.mark();
log.warn("Command timeout exception ({}-pubsub)", this.name, e);
log.warn("[{}] Command timeout exception ({}-pubsub)", Thread.currentThread().getName(), this.name, e);
if (wroteThreadDump.compareAndSet(false, true)) {
ThreadDumpUtil.writeThreadDump();

View File

@ -163,7 +163,7 @@ public class FaultTolerantRedisCluster {
private void recordCommandTimeout(final RedisCommandTimeoutException e) {
commandTimeoutMeter.mark();
log.warn("Command timeout exception ({})", this.name, e);
log.warn("[{}] Command timeout exception ({})", Thread.currentThread().getName(), this.name, e);
if (wroteThreadDump.compareAndSet(false, true)) {
ThreadDumpUtil.writeThreadDump();