diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java index ff735124b5..a77a890778 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java @@ -869,7 +869,7 @@ protected int selectDataAndRoute(ProcessInfo processInfo, ChannelRouterContext c log.info( "Routing for channel '{}' has been processing for {} seconds. The following stats have been gathered: " + "totalDataRoutedCount={}, totalDataEventCount={}, startDataId={}, endDataId={}, dataReadCount={}, peekAheadFillCount={}, transactions={}, dataGaps={}", - new Object[] { context.getChannel().getChannelId(), totalDataCount, totalDataEventCount, ((System.currentTimeMillis()-startTime) / 1000), context.getStartDataId(), + new Object[] { context.getChannel().getChannelId(), ((System.currentTimeMillis()-startTime) / 1000), totalDataCount, totalDataEventCount, context.getStartDataId(), context.getEndDataId(), context.getDataReadCount(), context.getPeekAheadFillCount(), context.getTransactions().toString(), context.getDataGaps().toString() }); ts = System.currentTimeMillis(); @@ -881,6 +881,14 @@ protected int selectDataAndRoute(ProcessInfo processInfo, ChannelRouterContext c data = null; } } while (data != null); + + long routeTime = System.currentTimeMillis() - startTime; + if (routeTime > 60000 && context != null) { + log.info( + "Done routing for channel '{}' which took {} seconds", + new Object[] { context.getChannel().getChannelId(), ((System.currentTimeMillis() - startTime) / 1000) }); + ts = System.currentTimeMillis(); + } } finally { reader.setReading(false);