|
|
|
@ -118,7 +118,7 @@ public class TbMsgGeneratorNode implements TbNode { |
|
|
|
} |
|
|
|
}, |
|
|
|
t -> { |
|
|
|
log.warn("onMsg onFailure callback, took {}ms, config {}, msg {}, exception {}", sw.stopAndGetTotalTimeMillis(), config, msg, t); |
|
|
|
log.trace("onMsg onFailure callback, took {}ms, config {}, msg {}", sw.stopAndGetTotalTimeMillis(), config, msg, t); |
|
|
|
if (initialized.get() && (config.getMsgCount() == TbMsgGeneratorNodeConfiguration.UNLIMITED_MSG_COUNT || currentMsgCount < config.getMsgCount())) { |
|
|
|
ctx.tellFailure(msg, t); |
|
|
|
scheduleTickMsg(ctx); |
|
|
|
|