I am using ES 1.1.1 and Java 1.7u5. Deployed a intermediate WAR that queries Elasticsearch in Amazon EC2 instance. The problem with this approach is the querying is working fine for some time and after that there is no communication between WAR(tomcat) and ES !! This random failure is very uncomfortable. Now that this system is in dev, it is not a big problem.
Before the main problem is resolved, I am with the idea of using existing queries in Java with a minor modification. I plan to call ES on 9200(rest call) instead of TransportClient(9300 port) and parse the response string and build SearchResponse object. But I am not able to build valid StreamInput object from Http Response Stream.
If someone can throw some light on how to achieve this, this will be of great help.