com.atlassian.confluence.search.elasticsearch

Class ESJournalIndexTaskQueue

java.lang.Object

com.atlassian.confluence.search.queue.AbstractJournalIndexTaskQueue<ESTask>

com.atlassian.confluence.search.elasticsearch.ESJournalIndexTaskQueue

All Implemented Interfaces:

IndexTaskQueue<ESTask>

@Internal
public class ESJournalIndexTaskQueue
extends AbstractJournalIndexTaskQueue<ESTask>

A queue of ESTasks.

Since:

5.9.

Field Summary

Fields inherited from class com.atlassian.confluence.search.queue.AbstractJournalIndexTaskQueue

anyTypeDao, indexFlushRequester, JOURNAL_ID, journalService

Constructor Summary

Constructors

Constructor and Description
ESJournalIndexTaskQueue(JournalService journalService, AnyTypeDao anyTypeDao, IndexFlushRequester indexFlushRequester, ESIndexTaskFactory esIndexTaskFactory)

Method Summary

Modifier and Type	Method and Description
protected Iterable<JournalEntry>	preProcessJournalEntries(Iterable<JournalEntry> entries)
protected Optional<JournalEntry>	toEntry(ESTask task) Convert a task into a journal entry.
protected ESTask	toTask(JournalEntry entry) Convert an entry to a task.

Methods inherited from class com.atlassian.confluence.search.queue.AbstractJournalIndexTaskQueue

enqueue, enqueueAll, flushQueue, flushQueue, flushQueue, flushQueue, flushQueueWithActionOnIterableOfTasks, getQueuedEntries, getSize, reset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ESJournalIndexTaskQueue

public ESJournalIndexTaskQueue(JournalService journalService,
                               AnyTypeDao anyTypeDao,
                               IndexFlushRequester indexFlushRequester,
                               ESIndexTaskFactory esIndexTaskFactory)

Method Detail

toTask

protected ESTask toTask(JournalEntry entry)

Description copied from class: AbstractJournalIndexTaskQueue

Convert an entry to a task.

Specified by:

toTask in class AbstractJournalIndexTaskQueue<ESTask>

Parameters:

entry - a journal entry.

Returns:

a task

toEntry

protected Optional<JournalEntry> toEntry(ESTask task)

Description copied from class: AbstractJournalIndexTaskQueue

Convert a task into a journal entry.

Specified by:

toEntry in class AbstractJournalIndexTaskQueue<ESTask>

Parameters:

task - a task

Returns:

a journal entry

preProcessJournalEntries

protected Iterable<JournalEntry> preProcessJournalEntries(Iterable<JournalEntry> entries)

Specified by:

preProcessJournalEntries in class AbstractJournalIndexTaskQueue<ESTask>