com.atlassian.confluence.search.lucene.queue

Class JournalIndexTaskQueue

java.lang.Object

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

com.atlassian.confluence.search.lucene.queue.JournalIndexTaskQueue

All Implemented Interfaces:

IndexTaskQueue<ConfluenceIndexTask>

public class JournalIndexTaskQueue
extends AbstractJournalIndexTaskQueue<ConfluenceIndexTask>

A queue of ConfluenceIndexTasks.

Since:

5.6

Field Summary

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

anyTypeDao, indexFlushRequester, JOURNAL_ID, journalService

Constructor Summary

Constructors

Constructor and Description
JournalIndexTaskQueue(JournalService journalService, IndexTaskFactory indexTaskFactory, AnyTypeDao anyTypeDao) Deprecated. since 5.9.0
JournalIndexTaskQueue(JournalService journalService, IndexTaskFactory indexTaskFactory, AnyTypeDao anyTypeDao, IndexFlushRequester indexFlushRequester)

Method Summary

Modifier and Type	Method and Description
protected Iterable<JournalEntry>	preProcessJournalEntries(Iterable<JournalEntry> entries)
protected Optional<JournalEntry>	toEntry(ConfluenceIndexTask task) Converts an IndexQueueEntry to an IndexTask.
protected ConfluenceIndexTask	toTask(JournalEntry entry) Converts an IndexQueueEntry to an IndexTask.

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

JournalIndexTaskQueue

@Deprecated
public JournalIndexTaskQueue(JournalService journalService,
                                         IndexTaskFactory indexTaskFactory,
                                         AnyTypeDao anyTypeDao)

Deprecated. since 5.9.0

JournalIndexTaskQueue

public JournalIndexTaskQueue(JournalService journalService,
                             IndexTaskFactory indexTaskFactory,
                             AnyTypeDao anyTypeDao,
                             IndexFlushRequester indexFlushRequester)

Since:

5.9.0

Method Detail

toTask

protected ConfluenceIndexTask toTask(JournalEntry entry)

Converts an IndexQueueEntry to an IndexTask.

Specified by:

toTask in class AbstractJournalIndexTaskQueue<ConfluenceIndexTask>

Parameters:

entry - a journal entry.

Returns:

the converted entry, or NoOpIndexTask if the entry is invalid (say the searchable for an add task no longer exists).

toEntry

protected Optional<JournalEntry> toEntry(ConfluenceIndexTask task)

Converts an IndexQueueEntry to an IndexTask.

Specified by:

toEntry in class AbstractJournalIndexTaskQueue<ConfluenceIndexTask>

Parameters:

task - a task

Returns:

the converted entry, or null if the entry is invalid (say the searchable for an add task no longer exists).

preProcessJournalEntries

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

Specified by:

preProcessJournalEntries in class AbstractJournalIndexTaskQueue<ConfluenceIndexTask>