Send 500 events at a time and wait between sends.

Author: trotter

lib/cube/emitter-http.js

@@ -9,10 +9,10 @@ module.exports = function(protocol, host, port) {
   if (protocol != "http:") throw new Error("invalid HTTP protocol");
 
   function send() {
-    var event = queue.shift();
-    if (!event) return;
+    var events = queue.splice(0, 500);
+    if (events.length === 0) return;
 
-    var body = JSON.stringify(event);
+    var body = JSON.stringify(events);
 
     var postOptions = {
       host: host,
@@ -26,11 +26,12 @@ module.exports = function(protocol, host, port) {
     };
 
     var postRequest = http.request(postOptions, function(res) {
-      if (queue.length) process.nextTick(send);
+      if (queue.length) setTimeout(send, 500);
     });
 
     postRequest.on('error', function (e) {
       console.warn(e.message);
+      // TODO: Add events back to queue on error
     });
 
     postRequest.write(body);