From db97d536c778b65d2c4691c7e6f0d340f60fdbbd Mon Sep 17 00:00:00 2001
From: gdusbabek <gdusbabek@gmail.com>
Date: Mon, 20 Dec 2010 10:28:25 -0600
Subject: [PATCH] handle possibly null (invalid) records

---
 src/com/rackspace/flewton/CollectorHandler.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/com/rackspace/flewton/CollectorHandler.java b/src/com/rackspace/flewton/CollectorHandler.java
index 69236d3..94c4e6d 100644
--- a/src/com/rackspace/flewton/CollectorHandler.java
+++ b/src/com/rackspace/flewton/CollectorHandler.java
@@ -69,6 +69,7 @@ record = new Recordv5(buff);
                     break;
                 default:
                     if (logUnhandledVersions) {
+                        // this means the record stays null. we need to check for that when handling.
                         logger.warn(String.format("Netflow v%d is not supported", version));
                         if (logger.isDebugEnabled())
                             logPacket(e.getRemoteAddress(), buff.duplicate());
@@ -82,8 +83,9 @@ record = new Recordv5(buff);
         }
         
         // Send record to backends
-        for (AbstractBackend backend : backEnds)
-            backend.write(record);
+        if (record != null)
+            for (AbstractBackend backend : backEnds)
+                backend.write(record);
     }
     
     // dumps the contents of a buffer