Package com.atlassian.confluence.plugins.edgeindex

Class JournalEdgeIndexTaskQueue

java.lang.Object

com.atlassian.confluence.plugins.edgeindex.JournalEdgeIndexTaskQueue

All Implemented Interfaces:

EdgeIndexTaskQueue

@Component
public class JournalEdgeIndexTaskQueue
extends Object
implements EdgeIndexTaskQueue

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BATCH_SIZE

Constructor Summary

Constructors

Constructor	Description
JournalEdgeIndexTaskQueue(IndexJournalService journalService, EdgeIndexTaskFactory edgeIndexTaskFactory, com.atlassian.sal.api.transaction.TransactionTemplate transactionTemplate, NonFlushingSessionWrapper hibernateNonFlushingSessionWrapper, ObjectMapperProvider objectMapperProvider)

Method Summary

Modifier and Type	Method	Description
void	enqueue(IndexTaskType indexTaskType, ContentEntityObject target)	Add a new task to this queue.
void	enqueue(IndexTaskType indexTaskType, Edge edge)	Add a new task to this queue.
void	enqueue(IndexTaskType indexTaskType, RebuildIndexTask.RebuildIndexParams rebuildIndexParams)	Adds a RebuildIndexTask to the the queue
long	getSize()	Retrieve the number of elements in the queue.
void	processEntries(com.atlassian.fugue.Effect<EdgeIndexTask> action)	Apply the given action to contents of the queue.

Methods inherited from class java.lang.Object

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

Field Details

BATCH_SIZE

public static final int BATCH_SIZE

See Also:

• Constant Field Values

Constructor Details

JournalEdgeIndexTaskQueue

@Autowired
public JournalEdgeIndexTaskQueue(IndexJournalService journalService,
 EdgeIndexTaskFactory edgeIndexTaskFactory,
 com.atlassian.sal.api.transaction.TransactionTemplate transactionTemplate,
 NonFlushingSessionWrapper hibernateNonFlushingSessionWrapper,
 ObjectMapperProvider objectMapperProvider)

Method Details

enqueue

public void enqueue(IndexTaskType indexTaskType,
 ContentEntityObject target)

Description copied from interface: EdgeIndexTaskQueue

Add a new task to this queue.

Specified by:

enqueue in interface EdgeIndexTaskQueue

enqueue

public void enqueue(IndexTaskType indexTaskType,
 Edge edge)

Description copied from interface: EdgeIndexTaskQueue

Add a new task to this queue.

Specified by:

enqueue in interface EdgeIndexTaskQueue

enqueue

public void enqueue(IndexTaskType indexTaskType,
 RebuildIndexTask.RebuildIndexParams rebuildIndexParams)

Description copied from interface: EdgeIndexTaskQueue

Adds a RebuildIndexTask to the the queue

Specified by:

enqueue in interface EdgeIndexTaskQueue

getSize

public long getSize()

Description copied from interface: EdgeIndexTaskQueue

Retrieve the number of elements in the queue.

Specified by:

getSize in interface EdgeIndexTaskQueue

Returns:

size of the queue.

processEntries

public void processEntries(com.atlassian.fugue.Effect<EdgeIndexTask> action)

Description copied from interface: EdgeIndexTaskQueue

Apply the given action to contents of the queue. Processing is stopped immediately if the action throws an exception when processing an element. Next call to processEntries will start from the failing element.

Specified by:

processEntries in interface EdgeIndexTaskQueue

Parameters:

action - action to apply queue contents