Package com.atlassian.confluence.impl.journal

Class DefaultJournalManager

java.lang.Object

com.atlassian.confluence.impl.journal.DefaultJournalManager

All Implemented Interfaces:

JournalManager

public class DefaultJournalManager
extends Object
implements JournalManager

This is the default implementation of JournalManager.

Since:

5.6

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultJournalManager.IgnoreSettings	Settings for ignoring journal entries added within the last given milliseconds.

Constructor Summary

Constructors

Constructor	Description
DefaultJournalManager(JournalDao journalDao, JournalStateStore journalStateStore, DefaultJournalManager.IgnoreSettings ignoreSettings)

Method Summary

Modifier and Type	Method	Description
int	countEntries(@NonNull JournalIdentifier journalId)	Counts the number of entries in a journal.
long	enqueue(@NonNull JournalEntry entry)	Adds the given entry to a journal.
void	enqueue(@NonNull Collection<JournalEntry> entries)	Adds a collection of entries to a journal.
long	getIgnoreWithinMillis()
Optional<JournalEntry>	getMostRecentId(@NonNull JournalIdentifier journalIdentifier)	Gets the most recent entry in the journal for the given journal identifier
Iterable<JournalEntry>	peek(@NonNull JournalIdentifier journalId, int maxEntries)	Return a copy of journal entries that are waiting to be processed.
<V> V	processNewEntries(@NonNull JournalIdentifier journalId, int maxEntries, @NonNull Function<Iterable<JournalEntry>,@NonNull EntryProcessorResult<V>> entryProcessor)	Processes journal entries that were added since the last time this method was called for this journal on this cluster node.
void	reset(@NonNull JournalIdentifier journalId)	Resets the state of the journal so that all entries currently in the journal will be skipped.
void	setMostRecentId(@NonNull JournalIdentifier journalIdentifier, long id)	Stores the most recent journal entry id in the journal store
void	setMostRecentId(@NonNull JournalEntry journalEntry)	Stores the most recent journal entry id in the journal store
void	waitForRecentEntriesToBecomeVisible()	Waits long enough to ensure that entries added before calling this method will be available to subsequent call to JournalManager.processNewEntries(JournalIdentifier, int, Function).

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.confluence.impl.journal.JournalManager

processEntries

Constructor Detail

DefaultJournalManager

public DefaultJournalManager(JournalDao journalDao,
                             JournalStateStore journalStateStore,
                             DefaultJournalManager.IgnoreSettings ignoreSettings)

Method Detail

enqueue

public long enqueue(@NonNull JournalEntry entry)

Description copied from interface: JournalManager

Adds the given entry to a journal.

New journal is automatically created if a journal with the given name does not exists.

Specified by:

enqueue in interface JournalManager

Parameters:

entry - entry to persist

Returns:

id generated for the entry

enqueue

public void enqueue(@NonNull Collection<JournalEntry> entries)
             throws ServiceException

Description copied from interface: JournalManager

Adds a collection of entries to a journal.

Specified by:

enqueue in interface JournalManager

Parameters:

entries - entries to persist

Throws:

ServiceException - if one of entries could not be persisted. In this case, the transaction is rolled back and no entries are persisted

peek

public Iterable<JournalEntry> peek(@NonNull JournalIdentifier journalId,
                                   int maxEntries)

Description copied from interface: JournalManager

Return a copy of journal entries that are waiting to be processed.

Specified by:

peek in interface JournalManager

Parameters:

journalId - only entries with this journal id will be returned

maxEntries - maximum number of entries to return

Returns:

a copy of journal entries that are waiting to be processed

reset

public void reset(@NonNull JournalIdentifier journalId)

Description copied from interface: JournalManager

Resets the state of the journal so that all entries currently in the journal will be skipped.

Specified by:

reset in interface JournalManager

Parameters:

journalId - identifier of the journal to reset

countEntries

public int countEntries(@NonNull JournalIdentifier journalId)

Description copied from interface: JournalManager

Counts the number of entries in a journal.

Specified by:

countEntries in interface JournalManager

Parameters:

journalId - identifier of the journal

processNewEntries

public <V> V processNewEntries(@NonNull JournalIdentifier journalId,
                               int maxEntries,
                               @NonNull Function<Iterable<JournalEntry>,@NonNull EntryProcessorResult<V>> entryProcessor)
                        throws org.springframework.dao.DataAccessException

Description copied from interface: JournalManager

Processes journal entries that were added since the last time this method was called for this journal on this cluster node.

This method does not return entries that were added immediately before calling this method. Use JournalManager.waitForRecentEntriesToBecomeVisible() for ensuring these entries will be included.

This method can miss some entries due to identifier assignment and entry insertion not being an atomic operation. The risk of missed entries can be reduced by creating new entries as close to transaction commit as possible.

If entryProcessor throws an exception, the same entries will be returned again when this method is next called for this journal on this cluster node.

New journal is automatically created if a journal with the given name does not exists.

Specified by:

processNewEntries in interface JournalManager

Parameters:

journalId - only entries with this journal id will be returned

maxEntries - maximum number of entries to process

entryProcessor - function that will process entries that were added since the last time

Returns:

result of entryProcessor

Throws:

org.springframework.dao.DataAccessException - if entries could not be fetched or the journal state could not be saved

waitForRecentEntriesToBecomeVisible

public void waitForRecentEntriesToBecomeVisible()
                                         throws InterruptedException

Description copied from interface: JournalManager

Waits long enough to ensure that entries added before calling this method will be available to subsequent call to JournalManager.processNewEntries(JournalIdentifier, int, Function).

Specified by:

waitForRecentEntriesToBecomeVisible in interface JournalManager

Throws:

InterruptedException - if the thread got interrupted

getIgnoreWithinMillis

public long getIgnoreWithinMillis()

Specified by:

getIgnoreWithinMillis in interface JournalManager

Returns:

the time that new entries are ignored

getMostRecentId

public Optional<JournalEntry> getMostRecentId(@NonNull JournalIdentifier journalIdentifier)
                                       throws org.springframework.dao.DataAccessException

Description copied from interface: JournalManager

Gets the most recent entry in the journal for the given journal identifier

Specified by:

getMostRecentId in interface JournalManager

Parameters:

journalIdentifier - journal to obtain the most recent entry

Returns:

the most recent entry or Optional.empty() if none found

Throws:

org.springframework.dao.DataAccessException

setMostRecentId

public void setMostRecentId(@NonNull JournalIdentifier journalIdentifier,
                            long id)
                     throws org.springframework.dao.DataAccessException

Description copied from interface: JournalManager

Stores the most recent journal entry id in the journal store

Specified by:

setMostRecentId in interface JournalManager

Parameters:

journalIdentifier - identifier of the journal to store the most recent id

id - value of the most recent id

Throws:

org.springframework.dao.DataAccessException - if entries could not be fetched or the journal state could not be saved

setMostRecentId

public void setMostRecentId(@NonNull JournalEntry journalEntry)
                     throws org.springframework.dao.DataAccessException

Description copied from interface: JournalManager

Stores the most recent journal entry id in the journal store

Specified by:

setMostRecentId in interface JournalManager

Parameters:

journalEntry - journal entry to store as the most recent

Throws:

org.springframework.dao.DataAccessException - if entries could not be fetched or the journal state could not be saved