Skip to content

Commit

Permalink
Improve logging.
Browse files Browse the repository at this point in the history
Signed-off-by: Achim Kraus <achim.kraus@bosch-si.com>
  • Loading branch information
Achim Kraus committed Feb 14, 2018
1 parent 82bbf7b commit 54828e7
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -438,13 +438,13 @@ private <K> void dumpExchanges(int logMaxExchanges, Set<Entry<K, Exchange>> exch
Request current = exchange.getCurrentRequest();
String pending = exchange.getRetransmissionHandle() == null ? "" : "/pending";
if (origin != current && !origin.getToken().equals(current.getToken())) {
HEALTH_LOGGER.info(" {}, complete {}, retransmission {}{}, org {}, {}, {}", exchangeEntry.getKey(),
exchange.isComplete(), exchange.getFailedTransmissionCount(), pending, origin.getToken(),
HEALTH_LOGGER.info(" {}, {}, retransmission {}{}, org {}, {}, {}", exchangeEntry.getKey(),
exchange, exchange.getFailedTransmissionCount(), pending, origin.getToken(),
current, exchange.getCurrentResponse());
} else {
String mark = origin == null ? "-" : "+";
HEALTH_LOGGER.info(" {}, complete {}, retransmission {}{}, {} {}, {}", exchangeEntry.getKey(),
exchange.isComplete(), exchange.getFailedTransmissionCount(), pending, mark, current,
String mark = origin == null ? "(missing origin request) " : "";
HEALTH_LOGGER.info(" {}, {}, retransmission {}{}, {}{}, {}", exchangeEntry.getKey(),
exchange, exchange.getFailedTransmissionCount(), pending, mark, current,
exchange.getCurrentResponse());
}
if (HEALTH_LOGGER.isDebugEnabled()) {
Expand Down

0 comments on commit 54828e7

Please sign in to comment.