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

Implementation of EdgeIndexTaskQueue that used journal as the backing store.

Since:

5.6

Field Summary

Fields

Modifier and Type	Field and Description
static int	BATCH_SIZE

Constructor Summary

Constructors

Constructor and Description
JournalEdgeIndexTaskQueue(JournalService journalManager, EdgeIndexTaskFactory edgeIndexTaskFactory, com.atlassian.sal.api.transaction.TransactionTemplate transactionTemplate)

Method Summary

Modifier and Type	Method and 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	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 Detail

BATCH_SIZE

public static final int BATCH_SIZE

See Also:

Constant Field Values

Constructor Detail

JournalEdgeIndexTaskQueue

@Autowired
public JournalEdgeIndexTaskQueue(@Qualifier(value="journalService")
                                            JournalService journalManager,
                                            EdgeIndexTaskFactory edgeIndexTaskFactory,
                                            com.atlassian.sal.api.transaction.TransactionTemplate transactionTemplate)

Method Detail

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

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