Delete Empty emitting from triggers

Author: shulkaolka

src/main/java/io/elastic/jdbc/triggers/GetRowsPollingTrigger.java

@@ -83,23 +83,14 @@ public final void execute(ExecutionParameters parameters) {
           .rowsPolling(pollingField, pollingValue);
       query.setMaxPollingValue(cts);
       ArrayList<JsonObject> resultList = query.executePolling(connection);
+
       for (int i = 0; i < resultList.size(); i++) {
         LOGGER.info("Columns count: {} from {}", i + 1, resultList.size());
         LOGGER.info("Emitting data {}", resultList.get(i).toString());
         parameters.getEventEmitter()
             .emitData(new Message.Builder().body(resultList.get(i)).build());
       }
 
-      if (resultList.size() == 0) {
-        resultList.add(Json.createObjectBuilder()
-            .add("empty dataset", "no data")
-            .build());
-        LOGGER.info("Emitting empty data");
-        query.setMaxPollingValue(new java.sql.Timestamp(System.currentTimeMillis()));
-        parameters.getEventEmitter()
-            .emitData(new Message.Builder().body(resultList.get(0)).build());
-      }
-
       formattedDate = new SimpleDateFormat(PROPERTY_DATETIME_FORMAT)
           .format(query.getMaxPollingValue());
 

src/main/java/io/elastic/jdbc/triggers/SelectTrigger.java

@@ -84,15 +84,6 @@ public final void execute(ExecutionParameters parameters) {
             .emitData(new Message.Builder().body(resultList.get(i)).build());
       }
 
-      if (resultList.size() == 0) {
-        resultList.add(Json.createObjectBuilder()
-            .add("empty dataset", "no data")
-            .build());
-        LOGGER.info("Emitting data {}", resultList.get(0).toString());
-        parameters.getEventEmitter()
-            .emitData(new Message.Builder().body(resultList.get(0)).build());
-      }
-
       snapshot = Json.createObjectBuilder()
           .add(PROPERTY_SKIP_NUMBER, skipNumber + resultList.size())
           .add(LAST_POLL_PLACEHOLDER, pollingValue.toString())