Simple http-streaming and websocket implementation of an ElasticSearch river: http://www.elasticsearch.org/guide/reference/river/ See the Wiki for additional documentation and examples
spinisetti/streaming-river
ElasticSearch plugin that will index content streamed from an HTML 5 WebSocket or standard HTTP
Scala