Package com.atlassian.confluence.impl.journal

Class BandanaJournalStateStore

java.lang.Object

com.atlassian.confluence.impl.journal.BandanaJournalStateStore

All Implemented Interfaces:

JournalStateStore

@Internal
public class BandanaJournalStateStore
extends Object
implements JournalStateStore

Stores journal queue state in bandana.

Since:

5.9

Constructor Summary

Constructors

Constructor	Description
BandanaJournalStateStore(BandanaPersister bandanaPersister, BandanaContext bandanaContext)

Method Summary

Modifier and Type	Method	Description
long	getMostRecentId(@NonNull JournalIdentifier journalId)	Returns the most recent id for a journal or 0 if no id has been stored yet.
void	resetAllJournalStates()	Resets the state of all journals.
void	setMostRecentId(@NonNull JournalIdentifier journalId, long id)	Set the most recent identifier for a journal.

Methods inherited from class java.lang.Object

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

Constructor Details

BandanaJournalStateStore

public BandanaJournalStateStore(BandanaPersister bandanaPersister,
 BandanaContext bandanaContext)

Method Details

getMostRecentId

public long getMostRecentId(@NonNull JournalIdentifier journalId)
                     throws org.springframework.dao.DataAccessException

Description copied from interface: JournalStateStore

Returns the most recent id for a journal or 0 if no id has been stored yet.

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

Specified by:

getMostRecentId in interface JournalStateStore

Parameters:

journalId - id of the journal

Returns:

most recent id for a journal or 0 if no id has been stored yet

Throws:

org.springframework.dao.DataAccessException - if reading the id failed

setMostRecentId

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

Description copied from interface: JournalStateStore

Set the most recent identifier for a journal.

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

Only positive identifiers (e.g. > 0) can be stored.

Specified by:

setMostRecentId in interface JournalStateStore

Parameters:

journalId - id of the journal

id - identifier to store as the most recent id

Throws:

org.springframework.dao.DataAccessException - if persisting the id failed.

resetAllJournalStates

public void resetAllJournalStates()
                           throws org.springframework.dao.DataAccessException

Description copied from interface: JournalStateStore

Resets the state of all journals.

After calling this method all JournalStateStore.getMostRecentId(JournalIdentifier) calls will initially return 0.

Specified by:

resetAllJournalStates in interface JournalStateStore

Throws:

org.springframework.dao.DataAccessException - if reset fails