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

var FIFO = new d();

fetcher();

var udpserver = dgram.createSocket("udp4");

udpserver.on("message",
    function (msg, rinfo) {
        FIFO.push(msg.toString());
        //console.log("MSG", msg);
    }
);

udpserver.bind(4444);

var index =0;

function fetcher () {
    while (FIFO.length > 0)
    {
        index++;
        var msg = FIFO.shift();
        rClient.hset("raw", "data"+index, msg);
        console.log("Successed", index);
    }
}

///
@@ -140,23 +140,20 @@
 w d();%0A%0A
-fetcher
+init
 ();%0A%0Avar
@@ -377,15 +377,12 @@
 ion 
-fetcher
+init
  () 

Update UDPefef