}

        /**
         * Returns the event timestamp in milliseconds.
         *
         * @return the event timestamp in milliseconds
         */
        public long getTimestamp() {
            return timestamp;
        }

        /**
         * Returns the log level name.
         *
         * @return the log level name
         */
        public String getLevel() {

                    source.put("message", event.getMessage());
                    source.put("throwable", event.getThrowable() != null ? event.getThrowable() : "");
                    source.put("timestamp", event.getTimestamp());
                    bulkRequest.add(client.prepareIndex().setIndex(indexName).setSource(source));
                }
                final BulkResponse response = bulkRequest.execute().actionGet(30_000L);

        for (int i = 0; i < displayCount; i++) {
            final LogNotificationEvent event = events.get(i);
            final String timestamp = TIMESTAMP_FORMATTER.format(Instant.ofEpochMilli(event.getTimestamp()));
            String message = event.getMessage();
            if (message != null && message.length() > maxMessageLength) {
                message = message.substring(0, maxMessageLength) + "...";
            }

                -1, new String[] { "tag1" }, new String[] { SuggestConstants.DEFAULT_ROLE }, null, SuggestItem.Kind.DOCUMENT);
        oldItem.setTimestamp(ZonedDateTime.now().minusMinutes(1));
        suggester.indexer().index(oldItem);
        suggester.refresh();

        long oldWordsCount = suggester.getAllWordsNum();
        assertTrue(oldWordsCount > 0);