Comments around needed suspend/ignore work.

JumpMind · Sep 10, 2009 · da93ca1 · da93ca1
1 parent eb6b9a7
commit da93ca1
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -293,6 +293,12 @@ public boolean extract(Node node, IOutgoingTransport targetTransport) throws IOE
 
         List<OutgoingBatch> batches = outgoingBatchService.getOutgoingBatches(node.getNodeId());
         if (batches != null && batches.size() > 0) {
+
+            // reserve here....
+
+            // based on results, filter all  AND my local getNodeChannel()!
+
+           // batches.get(0).setStatus(status)
             FileOutgoingTransport fileTransport = null;
 
             try {
@@ -304,9 +310,16 @@ public boolean extract(Node node, IOutgoingTransport targetTransport) throws IOE
                 ExtractStreamHandler handler = new ExtractStreamHandler(dataExtractor,
                         fileTransport != null ? fileTransport : targetTransport);
 
-                databaseExtract(node, batches, handler);
+                //verify skipping....
 
+                databaseExtract(node, batches, handler);
+
                 networkTransfer(fileTransport, targetTransport);
+
+         //       batch.setStatus(OutgoingBatch.Status.SE);  for IGNORED
+           //     outgoingBatchService.updateOutgoingBatch(batch);
+
+                //outgoingbatchservice - update status 
             } finally {
                 if (fileTransport != null) {
                     fileTransport.close();