Package com.atlassian.confluence.impl.incrementalsync

Class CachingIncrementalSyncSubscriptionManager

java.lang.Object

com.atlassian.confluence.impl.incrementalsync.CachingIncrementalSyncSubscriptionManager

All Implemented Interfaces:

IncrementalSyncSubscriptionManager

public class CachingIncrementalSyncSubscriptionManager
extends Object
implements IncrementalSyncSubscriptionManager

Caching for IncrementalSyncSubscriptionManager

Since:

9.4.0

Method Summary

Modifier and Type	Method	Description
static IncrementalSyncSubscriptionManager	create(IncrementalSyncSubscriptionManager delegate, com.atlassian.cache.CacheFactory cacheFactory)
Optional<IncrementalSyncSubscription>	getSubscription(long id)	Get an IncrementalSyncSubscription using Id
Collection<IncrementalSyncSubscription>	getSubscriptionsByContext(String context)	Get all subscription within a context
Collection<IncrementalSyncSubscription>	getSubscriptionsByContext(String context, IncrementalSyncState state)	Get all subscription within a context and state
int	removeAllSubscriptions(String contextKey)	Remove all subscription belong to a context key
int	removeDeletedSubscriptions(String contextKey)	Remove deleted subscription belong to a context key
int	removeExpiredSubscriptions(String contextKey, Instant ttl)	Remove expired subscription belong to a context key
boolean	removeSubscription(long id)	Remove a subscription using context key and subscription key
SubscriptionId	store(IncrementalSyncSubscription subscription)	Add or update an IncrementalSyncSubscription.

Methods inherited from class java.lang.Object

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

Method Details

create

public static IncrementalSyncSubscriptionManager create(IncrementalSyncSubscriptionManager delegate,
 com.atlassian.cache.CacheFactory cacheFactory)

store

public SubscriptionId store(IncrementalSyncSubscription subscription)

Description copied from interface: IncrementalSyncSubscriptionManager

Add or update an IncrementalSyncSubscription. It will determine whether IncrementalSyncSubscription is exits using Id or (context key + subscription key). If not exits then new IncrementalSyncSubscription will be inserted

Specified by:

store in interface IncrementalSyncSubscriptionManager

Returns:

getSubscription

public Optional<IncrementalSyncSubscription> getSubscription(long id)

Description copied from interface: IncrementalSyncSubscriptionManager

Get an IncrementalSyncSubscription using Id

Specified by:

getSubscription in interface IncrementalSyncSubscriptionManager

Returns:

getSubscriptionsByContext

public Collection<IncrementalSyncSubscription> getSubscriptionsByContext(String context)

Description copied from interface: IncrementalSyncSubscriptionManager

Get all subscription within a context

Specified by:

getSubscriptionsByContext in interface IncrementalSyncSubscriptionManager

Returns:

getSubscriptionsByContext

public Collection<IncrementalSyncSubscription> getSubscriptionsByContext(String context,
 IncrementalSyncState state)

Description copied from interface: IncrementalSyncSubscriptionManager

Get all subscription within a context and state

Specified by:

getSubscriptionsByContext in interface IncrementalSyncSubscriptionManager

Returns:

removeSubscription

public boolean removeSubscription(long id)

Description copied from interface: IncrementalSyncSubscriptionManager

Remove a subscription using context key and subscription key

Specified by:

removeSubscription in interface IncrementalSyncSubscriptionManager

Parameters:

id - the subscription's ID

Returns:

true if the subscription is removed successfully, false otherwise.

removeAllSubscriptions

public int removeAllSubscriptions(String contextKey)

Description copied from interface: IncrementalSyncSubscriptionManager

Remove all subscription belong to a context key

Specified by:

removeAllSubscriptions in interface IncrementalSyncSubscriptionManager

Parameters:

contextKey - the context key

Returns:

removeExpiredSubscriptions

public int removeExpiredSubscriptions(String contextKey,
 Instant ttl)

Description copied from interface: IncrementalSyncSubscriptionManager

Remove expired subscription belong to a context key

Specified by:

removeExpiredSubscriptions in interface IncrementalSyncSubscriptionManager

ttl - the time-to-live attribute

Returns:

removeDeletedSubscriptions

public int removeDeletedSubscriptions(String contextKey)

Description copied from interface: IncrementalSyncSubscriptionManager

Remove deleted subscription belong to a context key

Specified by:

removeDeletedSubscriptions in interface IncrementalSyncSubscriptionManager

Parameters:

contextKey - the context key

Returns: