com.atlassian.jira.index

Class PeriodicIndexWriterCommitScheduler

java.lang.Object

com.atlassian.jira.index.PeriodicIndexWriterCommitScheduler

public class PeriodicIndexWriterCommitScheduler
extends Object

Responsible for scheduling cyclical writer commit operation, storing uncommitted writers, and performing the actual commit calls.

Field Summary

Fields

Modifier and Type	Field and Description
static String	PERIODIC_COMMIT_BARRIER

Constructor Summary

Constructors

Constructor and Description
PeriodicIndexWriterCommitScheduler(PeriodicIndexWriterCommitObserver commitObserver, ApplicationProperties applicationProperties, BarrierFactory barrierFactory, com.atlassian.event.api.EventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and Description
protected void	commitWriters() Moves uncommitted writers from commit queue and attempts to commit them.
void	onPluginFrameworkShutdownEvent(com.atlassian.plugin.event.events.PluginFrameworkShutdownEvent event)
void	onPluginFrameworkStartedEvent(com.atlassian.plugin.event.events.PluginFrameworkStartedEvent event)
void	scheduleForCommit(DefaultIndexEngine.WriterReference writer) Add writer to commit queue.

Methods inherited from class java.lang.Object

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

Field Detail

PERIODIC_COMMIT_BARRIER

public static final String PERIODIC_COMMIT_BARRIER

See Also:

Constant Field Values

Constructor Detail

PeriodicIndexWriterCommitScheduler

public PeriodicIndexWriterCommitScheduler(PeriodicIndexWriterCommitObserver commitObserver,
                                          ApplicationProperties applicationProperties,
                                          BarrierFactory barrierFactory,
                                          com.atlassian.event.api.EventPublisher eventPublisher)

Method Detail

onPluginFrameworkStartedEvent

@EventListener
public void onPluginFrameworkStartedEvent(com.atlassian.plugin.event.events.PluginFrameworkStartedEvent event)

onPluginFrameworkShutdownEvent

@EventListener
public void onPluginFrameworkShutdownEvent(com.atlassian.plugin.event.events.PluginFrameworkShutdownEvent event)

scheduleForCommit

public void scheduleForCommit(DefaultIndexEngine.WriterReference writer)

Add writer to commit queue. It s 'commit' method will be called during next iteration of commitWriters()

Parameters:

writer -

commitWriters

protected void commitWriters()

Moves uncommitted writers from commit queue and attempts to commit them. Calls commitObserver on corresponding phases, even if the queue does not contain any writers to commit at the beginning of execution. Never throws an Throwable. In case any exceptions are thrown internally before operation was completed, moves all scheduled writers back to queue.