demo-websocket-client.js

/*

   npm install ws
   node demo-websocket-client.js
   ( ---> curl 'localhost:9200/myindex/_search')
   Ctrl-C

*/

var WebSocket = require('ws')
  ,socket = new WebSocket("ws://localhost:9400/websocket");        

socket.onopen = function() {
    socket.send(JSON.stringify({
        "type" : "index", 
        "data" : {
            "index" : "myindex",
            "type" : "mytype",
            "id" : "myid",
            "data" : {
                 "field1" : "value1",
                 "field2" : "value2"
            }
        }
    }));
    socket.send(JSON.stringify({
        "type" : "flush"
    }));
};

socket.onmessage = function(message) {
    console.log(message);
};

socket.onclose = function() {
    console.log("closed");
};