LOG.warn("Unable to process message <{}>: {}", msg.getId(), e);
} finally {
outgoingMessages.mark();
tcx.stop();
}
<BUG>LOG.debug("Finished processing message <{}>. Writing to output buffer.", msg.getId());
handleMessage(msg);
outgoingMessages.mark();
tcx.stop();</BUG>
}

LOG.warn("Unable to process message <{}>: {}", msg.getId(), e);
} finally {
outgoingMessages.mark();
tcx.stop();
}
}
