- short test for chunked gelf message pattern matching

lib/gelf_listener.js

@@ -2,21 +2,25 @@ var logger = require('log4js').getLogger();
 var dgram = require("dgram");
 var server = dgram.createSocket("udp4");
 var gelf = require("./gelf");
+var Binary = require('binary');
 var counter = 0;
 var queue;
 
 function start(port, p_queue) {
 	server.on("message", function (msg, rinfo) {
-		try {
-			message = gelf.decode(msg);
-		} catch(err) {
-			logger.error("Error parsing GELF message: " + err);
-			return;
-		}
-		counter = counter + 1;
+		gelf_header = Binary.parse(buf).word16lu('chunk_magic').vars;
+		if (gelf_header['chunk_magic'] == 3870) {
+			try {
+				message = gelf.decode(msg);
+			} catch(err) {
+				logger.error("Error parsing GELF message: " + err);
+				return;
+			}
+			counter = counter + 1;
 
-		queue.enqueue(message);
-		//console.log("count: " + counter);
+			queue.enqueue(message);
+			//console.log("count: " + counter);
+		}
 	});
 
 	server.on("listening", function () {