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('error', function (err) {
    console.log("Error Server", err);
})
udpserver.on("message",
    function (msg, rinfo) {
        FIFO.push(msg.toString());
    }
);

udpserver.bind(4444);

var index =0;

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

///
@@ -616,9 +616,4 @@
  %7D%0A%7D
-%0A%0A///

Update UDPefef