Skip to content
Permalink
Browse files

0003688: Routing can fail due to ConcurrentModificationException whil…

…e attempting to log "Routing for channel has been running..." (3.8)
  • Loading branch information...
mmichalek committed Nov 14, 2018
1 parent 7ca1576 commit ce41ccf37e6218bac77ebfd7a5e69f19701a009d
@@ -904,10 +904,9 @@ protected int selectDataAndRoute(ProcessInfo processInfo, ChannelRouterContext c
if (routeTs > 60000 && context != null) {
log.info(
"Routing for channel '{}' has been processing for {} seconds. The following stats have been gathered: "
+ "totalDataRoutedCount={}, totalDataEventCount={}, startDataId={}, endDataId={}, dataReadCount={}, peekAheadFillCount={}, transactions={}, dataGaps={}",
+ "totalDataRoutedCount={}, totalDataEventCount={}, startDataId={}, endDataId={}, dataReadCount={}, peekAheadFillCount={}, dataGaps={}",
new Object[] { context.getChannel().getChannelId(), ((System.currentTimeMillis()-startTime) / 1000), totalDataCount, totalDataEventCount, context.getStartDataId(),
context.getEndDataId(), context.getDataReadCount(), context.getPeekAheadFillCount(),
StringUtils.abbreviate(context.getTransactions().toString(), MAX_LOGGING_LENGTH),
StringUtils.abbreviate(context.getDataGaps().toString(), MAX_LOGGING_LENGTH) });
ts = System.currentTimeMillis();
}

0 comments on commit ce41ccf

Please sign in to comment.
You can’t perform that action at this time.