var d = require ('dequeue');
var redis = require("redis");
var rClient = redis.createClient();
var dgram = require("dgram");

var FIFO = new d();
var index =0;

fetcher();

var udpserver = dgram.createSocket("udp4");
udpserver.on('error', function (err) {
    console.log("Error Server", err);
})
udpserver.on("message",
    function (msg, rinfo) {
        index++;
        FIFO.push(msg.toString());

    }
);

udpserver.bind(4444);



function fetcher () {
    while (FIFO.length > 0)
    {
        var msg = FIFO.shift();

        rClient.hset("raw", "data"+index, msg);

    }
}
@@ -142,22 +142,8 @@
 d();
-%0Avar index =0;
 %0A%0Afe
@@ -200,88 +200,9 @@
 %22);%0A
-udpserver.on('error', function (err) %7B%0A    console.log(%22Error Server%22, err);%0A%7D)
 %0A
+
 udps
@@ -253,25 +253,8 @@
 ) %7B%0A
-        index++;%0A
     
@@ -284,17 +284,16 @@
 ing());%0A
-%0A
     %7D%0A);
@@ -317,17 +317,30 @@
 4444);%0A%0A
+var index =0;
 %0A
-
 %0Afunctio
@@ -388,16 +388,33 @@
 )%0A    %7B%0A
+        index++;%0A
         
@@ -437,17 +437,57 @@
 hift();%0A
+        console.log(%22Success: %22, index);
 %0A
-
         
@@ -530,12 +530,16 @@
 g);%0A
-%0A
     %7D%0A
-
 %7D
+%0A%0A///

Update UDPefef