0003658: Routing can fail due to ConcurrentModificationException while

attempting to log "Routing for channel has been running..."
JumpMind · Aug 3, 2018 · 8aa263c · 8aa263c
1 parent cbef108
commit 8aa263c
Showing 1 changed file with 3 additions and 4 deletions.
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
@@ -942,14 +942,13 @@ protected int selectDataAndRoute(ProcessInfo processInfo, ChannelRouterContext c
                         }
 
                         long routeTs = System.currentTimeMillis() - ts;
-                        if (routeTs > LOG_PROCESS_SUMMARY_THRESHOLD) {
+                        if (true || routeTs > LOG_PROCESS_SUMMARY_THRESHOLD) {
                             engine.getClusterService().refreshLock(ClusterConstants.ROUTE);
                             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), 
+                                            context.getEndDataId(), context.getDataReadCount(), context.getPeekAheadFillCount(), 
                                             StringUtils.abbreviate(context.getDataGaps().toString(), MAX_LOGGING_LENGTH)
                                             });
                             ts = System.currentTimeMillis();