From f9d63e857bae5b775c65399544602224659e3dd6 Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Fri, 26 Feb 2010 02:01:11 +0000
Subject: [PATCH] Fixed bug.  Need unit tests for unrouted data.

---
 .../jumpmind/symmetric/service/impl/RouterService.java    | 8 +++++---
 1 file changed, 5 insertions(+), 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
index e05c8d9713..b15917e30d 100644
--- 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);
 
             }