Package com.atlassian.confluence.internal.api.impl.service.incrementalsync.journal

Class ClientSubscriptionJournalStateStore

java.lang.Object

com.atlassian.confluence.internal.api.impl.service.incrementalsync.journal.ServerSubscriptionJournalStateStore

com.atlassian.confluence.internal.api.impl.service.incrementalsync.journal.ClientSubscriptionJournalStateStore

All Implemented Interfaces:

JournalStateStore, SubscriptionJournalStateStore

public class ClientSubscriptionJournalStateStore
extends ServerSubscriptionJournalStateStore

A Journal State Store which will store the state from MultiSubscriptionPerJournalIdentifier

Since:

9.3.0

Constructor Summary

Constructors

Constructor	Description
ClientSubscriptionJournalStateStore(String subscriptionContextKey, IncrementalSyncSubscriptionManager incrementalSyncSubscriptionManager)

Method Summary

Modifier and Type	Method	Description
protected String	getKeyPrefix()
long	getMostRecentId(@NonNull JournalIdentifier journalId)	Returns the most recent id for a journal or 0 if no id has been stored yet.

Methods inherited from class com.atlassian.confluence.internal.api.impl.service.incrementalsync.journal.ServerSubscriptionJournalStateStore

cleanUpSubscriptions, createNewSubscription, deactivateSubscription, getAvailableSubscriptions, getDeactivateSubscriptions, getSubscriptionContextKey, getSubscriptionStateData, isSubscriptionActive, removeSubscriptionStateData, resetAllJournalStates, saveSubscriptionStateData, setMostRecentId

Methods inherited from class java.lang.Object

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

Constructor Details

ClientSubscriptionJournalStateStore

public ClientSubscriptionJournalStateStore(String subscriptionContextKey,
 IncrementalSyncSubscriptionManager incrementalSyncSubscriptionManager)

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

Overrides:

getMostRecentId in class ServerSubscriptionJournalStateStore

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

getKeyPrefix

protected String getKeyPrefix()

Overrides:

getKeyPrefix in class ServerSubscriptionJournalStateStore