params.put("hosts", "IP");
params.put("queueName", "query");
params.put("exchangeName", "Exchangequery");
params.put("vHost", "/");
params.put("userName", "test");
params.put("password", "test");

Function<byte[], String> messageHandler = new Function<byte[], String>() {

    public String call(byte[] message) {
        return new String(message);
    }
};

JavaReceiverInputDStream<String> messages = RabbitMQUtils.createJavaStream(jssc, String.class, params, messageHandler);

messages.foreachRDD();

apple
orange

public static void main(String[] args) throws UnknownHostException {

    Client client = TransportClient.builder().build()
            .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host1"), 9300))
            .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host2"), 9300));

    List<String> messages = new ArrayList<>();
    messages.add("apple");
    messages.add("orange");

    String index = "fruit";
    String fieldName = "fruit_type";

    BoolQueryBuilder query = QueryBuilders.boolQuery();

    for (String message : messages) {
        query.should(QueryBuilders.matchQuery(fieldName, message));
        // alternative if you are not analyzing fields
        // query.should(QueryBuilders.termQuery(fieldName, message));
    }


    int size = 60; //you may want to change this since it defaults to 10
    SearchResponse response = client.prepareSearch(index).setQuery(query).setSize(size).execute().actionGet();

    long totalHits = response.getHits().getTotalHits();
    System.out.println("Found " + totalHits + " documents");
    for (SearchHit hit : response.getHits().getHits()) {
        System.out.println(hit.getSource());
    }
}

{
  "bool" : {
    "should" : [ {
      "match" : {
        "fruit_type" : {
          "query" : "apple",
          "type" : "boolean"
        }
      }
    }, {
      "match" : {
        "fruit_type" : {
          "query" : "orange",
          "type" : "boolean"
        }
      }
    } ]
  }
}