@Component public class JournalEdgeIndexTaskQueue extends Object implements EdgeIndexTaskQueue
Modifier and Type | Field and Description |
---|---|
static int |
BATCH_SIZE |
Constructor and Description |
---|
JournalEdgeIndexTaskQueue(JournalService journalManager,
EdgeIndexTaskFactory edgeIndexTaskFactory,
com.atlassian.sal.api.transaction.TransactionTemplate transactionTemplate) |
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.
|
public static final int BATCH_SIZE
@Autowired public JournalEdgeIndexTaskQueue(@Qualifier(value="journalService") JournalService journalManager, EdgeIndexTaskFactory edgeIndexTaskFactory, com.atlassian.sal.api.transaction.TransactionTemplate transactionTemplate)
public void enqueue(IndexTaskType indexTaskType, ContentEntityObject target)
EdgeIndexTaskQueue
enqueue
in interface EdgeIndexTaskQueue
public void enqueue(IndexTaskType indexTaskType, Edge edge)
EdgeIndexTaskQueue
enqueue
in interface EdgeIndexTaskQueue
public void processEntries(com.atlassian.fugue.Effect<EdgeIndexTask> action)
EdgeIndexTaskQueue
processEntries
in interface EdgeIndexTaskQueue
action
- action to apply queue contentsCopyright © 2003–2022 Atlassian. All rights reserved.