Fixed bug. Need unit tests for unrouted data.

JumpMind · Feb 26, 2010 · f9d63e8 · f9d63e8
1 parent 40a8496
commit f9d63e8
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java
@@ -367,16 +367,18 @@ protected void routeData(Data data, Map<String, Long> transactionIdDataId, Route
 
                 context.resetForNextData();
 
+                Collection<String> nodeIds = null;
                 if (!context.getChannel().isIgnoreEnabled()
                         && triggerRouter.isRouted(data.getEventType())) {
                     IDataRouter dataRouter = getDataRouter(triggerRouter);
                     context.addUsedDataRouter(dataRouter);
                     long ts = System.currentTimeMillis();
-                    Collection<String> nodeIds = dataRouter.routeToNodes(context, dataMetaData,
+                    nodeIds = dataRouter.routeToNodes(context, dataMetaData,
                             findAvailableNodes(triggerRouter, context), false);
-                    context.incrementStat(System.currentTimeMillis() - ts, STAT_DATA_ROUTER_MS);
-                    insertDataEvents(context, dataMetaData, nodeIds, triggerRouter);
+                    context.incrementStat(System.currentTimeMillis() - ts, STAT_DATA_ROUTER_MS);                    
                 }
+
+                insertDataEvents(context, dataMetaData, nodeIds, triggerRouter);
 
             }