final List<LogNotificationEvent> batch = events.subList(i, Math.min(i + BATCH_SIZE, events.size()));
                final BulkRequestBuilder bulkRequest = client.prepareBulk();
                for (final LogNotificationEvent event : batch) {
                    final Map<String, Object> source = new HashMap<>();
                    source.put("hostname", hostname);

    }

    /**
     * Prepares a bulk request builder.
     *
     * @return the bulk request builder
     */
    @Override
    public BulkRequestBuilder prepareBulk() {
        return client.prepareBulk();
    }

    /**
     * Gets a document asynchronously.
     *
     * @param request the get request
     * @return a future for the get response
     */

            } finally {
                SMailCallbackContext.clearPreparedMessageHookOnThread();
            }
        }

        final BulkRequestBuilder bulkDelete = client.prepareBulk();
        for (final String docId : docIds) {
            bulkDelete.add(client.prepareDelete().setIndex(indexName).setId(docId));
        }
        bulkDelete.execute().actionGet(fessConfig.getIndexSearchTimeout());