com.atlassian.confluence.impl.system

Class JournalSystemMaintenanceTaskQueue

java.lang.Object

com.atlassian.confluence.impl.system.JournalSystemMaintenanceTaskQueue

All Implemented Interfaces:

SystemMaintenanceTaskQueue

public class JournalSystemMaintenanceTaskQueue
extends Object
implements SystemMaintenanceTaskQueue

An implementation of the SystemMaintenanceTaskQueue that is backed by the Journal. SystemMaintenanceTasks that are placed in this queue are backed by the database journalentry table.

Since:

7.6.0

Constructor Summary

Constructors

Constructor and Description
JournalSystemMaintenanceTaskQueue(JournalService journalService, SystemMaintenanceTaskMarshalling taskMarshalling, SystemMaintenanceTaskRegistry taskRegistry, com.atlassian.sal.api.features.DarkFeatureManager darkFeatureManager)

Method Summary

Modifier and Type	Method and Description
void	enqueue(SystemMaintenanceTask task) Add a new task to this queue.
void	processEntries() 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

Constructor Detail

JournalSystemMaintenanceTaskQueue

public JournalSystemMaintenanceTaskQueue(JournalService journalService,
                                         SystemMaintenanceTaskMarshalling taskMarshalling,
                                         SystemMaintenanceTaskRegistry taskRegistry,
                                         com.atlassian.sal.api.features.DarkFeatureManager darkFeatureManager)

Method Detail

enqueue

public void enqueue(SystemMaintenanceTask task)

Description copied from interface: SystemMaintenanceTaskQueue

Add a new task to this queue.

Specified by:

enqueue in interface SystemMaintenanceTaskQueue

processEntries

public void processEntries()

Description copied from interface: SystemMaintenanceTaskQueue

Apply the given action to contents of the queue. If the action throws a MaintenanceTaskExecutionException when processing an element, processing will be stopped immediately and the next call to processEntries will start from the failing element. If any other exception type is thrown, the failed element will be skipped, and processing will continue.

Specified by:

processEntries in interface SystemMaintenanceTaskQueue