* Gets the message timestamp.
     *
     * @return the message timestamp
     */
    public LocalDateTime getTimestamp() {
        return timestamp;
    }

    /**
     * Sets the message timestamp.
     *
     * @param timestamp the message timestamp
     */
    public void setTimestamp(final LocalDateTime timestamp) {
        this.timestamp = timestamp;
    }

    /**

    }

    /**
     * Sets the timestamp of the suggest item.
     * @param timestamp The timestamp to set.
     */
    public void setTimestamp(final ZonedDateTime timestamp) {
        this.timestamp = timestamp;
    }

    /**
     * Sets the query frequency of the suggest item.
     * @param queryFreq The query frequency to set.
     */
    public void setQueryFreq(final long queryFreq) {

                2.0f, // userBoost
                new String[] { "tag1", "tag2" }, new String[] { "role1" }, new String[] {}, // languages
                SuggestItem.Kind.DOCUMENT);
        item.setTimestamp(ZonedDateTime.now());

        String bulkLine = SuggestUtil.createBulkLine("test_index", "_doc", item);
        assertNotNull(bulkLine);
        assertTrue(bulkLine.contains("test_index"));

        // Merge kinds
        mergedItem.setKinds(mergeKinds(item1.getKinds(), item2.getKinds()));

        // Take newer values from item2
        mergedItem.setTimestamp(item2.getTimestamp());
        mergedItem.setUserBoost(item2.getUserBoost());
        mergedItem.setEmptySource(item2.toEmptyMap());

        // Sum frequencies

        message.setContent("Test content");
        message.setTimestamp(timestamp);
        message.setSources(sources);

        assertEquals("msg-123", message.getId());
        assertEquals("assistant", message.getRole());
        assertEquals("Test content", message.getContent());
        assertEquals(timestamp, message.getTimestamp());
        assertSame(sources, message.getSources());
    }

    @Test

                itemKinds[i] = SuggestItem.Kind.USER;
            }
        }
        item.setKinds(itemKinds);

        item.setId(SuggestUtil.createSuggestTextId(text));
        item.setTimestamp(ZonedDateTime.ofInstant(Instant.ofEpochMilli(timestamp), Clock.systemDefaultZone().getZone()));
        return item;
    }

    /**
     * Creates an updated source map by merging the item with existing source.

                -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);

     */
    public void store(final DictionaryFile<? extends DictionaryItem> dictFile, final File file) {
        getDictionaryFile(dictFile.getId()).ifPresent(currentFile -> {
            if (currentFile.getTimestamp().getTime() > dictFile.getTimestamp().getTime()) {
                throw new DictionaryException(dictFile.getPath() + " was updated.");
            }

            // TODO use stream

                    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) + "...";
            }