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

Class ContentManagementIncrementalSyncServiceImpl

java.lang.Object

com.atlassian.confluence.internal.api.impl.service.incrementalsync.AbstractIncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

com.atlassian.confluence.internal.api.impl.service.incrementalsync.contentmanagement.ContentManagementIncrementalSyncServiceImpl

All Implemented Interfaces:

ContentManagementIncrementalSyncService, IncrementalSyncCleaner, IncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

public class ContentManagementIncrementalSyncServiceImpl
extends AbstractIncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>
implements ContentManagementIncrementalSyncService

Service class for managing content event related incremental sync operations with Bandana store.

Since:

9.3.0

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONTENT_MANAGEMENT_INC_SYNC_JOURNAL_NAME

Fields inherited from class com.atlassian.confluence.internal.api.impl.service.incrementalsync.AbstractIncrementalSyncService

clock, INCREMENTAL_SYNC_EVENTS_BATCH_LIMIT_PREFIX, incrementalSyncDataFetcher, journalService, logger, permissionManager, scopesRequestCacheDelegate, subscriptionJournalStateStore

Constructor Summary

Constructors

Constructor	Description
ContentManagementIncrementalSyncServiceImpl(JournalServiceInternal journalService, SubscriptionJournalStateStore subscriptionJournalStateStore, com.atlassian.core.util.Clock clock, PermissionManager permissionManager, IncrementalSyncDataFetcher<ContentManagementIncSyncModel> incrementalSyncDataFetcher, ScopesRequestCacheDelegate scopesRequestCacheDelegate)

Method Summary

Modifier and Type	Method	Description
int	getEventsBatchLimit()	Get max size of the events batch, that can be handled by the incremental sync service
protected SingleSubscriptionPerJournalIdentifier	getJournalIdentifier(long subscriptionId)
protected String	getJournalName()
Collection<? extends JournalIdentifier>	getManagedJournalIdentifier()	Return all Journal Entry names which is managed by this service including all deleted Subscription
protected String	getSubscriptionData(ContentSubscriptionSpec spec)
<E> void	handleEventForSubscription(E event, Consumer<JournalIdentifier> processor)	Based on input event this method will find a corresponding subscription which would like to handle it.
SubscriptionId	subscribe(ContentSubscriptionSpec spec)	Register to incremental api

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

cleanObsoleteData, cleanUpSubscriptions, getAvailableSubscriptions, getMostRecentCursor, isSubscriptionActive, processEvents, unsubscribe, verifyAdminUserOrManageSubscriptionScope, verifyAdminUserOrReadAllScope

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.internal.api.service.incrementalsync.IncrementalSyncService

cleanUpSubscriptions, getAvailableSubscriptions, getMostRecentCursor, isSubscriptionActive, processEvents, unsubscribe

Field Details

CONTENT_MANAGEMENT_INC_SYNC_JOURNAL_NAME

public static final String CONTENT_MANAGEMENT_INC_SYNC_JOURNAL_NAME

See Also:

• Constant Field Values

Constructor Details

ContentManagementIncrementalSyncServiceImpl

public ContentManagementIncrementalSyncServiceImpl(JournalServiceInternal journalService,
 SubscriptionJournalStateStore subscriptionJournalStateStore,
 com.atlassian.core.util.Clock clock,
 PermissionManager permissionManager,
 IncrementalSyncDataFetcher<ContentManagementIncSyncModel> incrementalSyncDataFetcher,
 ScopesRequestCacheDelegate scopesRequestCacheDelegate)

Method Details

subscribe

public SubscriptionId subscribe(ContentSubscriptionSpec spec)

Description copied from interface: IncrementalSyncService

Register to incremental api

Specified by:

subscribe in interface IncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

Overrides:

subscribe in class AbstractIncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

Parameters:

spec - the specification

Returns:

an unique id

getSubscriptionData

protected String getSubscriptionData(ContentSubscriptionSpec spec)

Specified by:

getSubscriptionData in class AbstractIncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

getJournalName

protected String getJournalName()

Specified by:

getJournalName in class AbstractIncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

getJournalIdentifier

protected SingleSubscriptionPerJournalIdentifier getJournalIdentifier(long subscriptionId)

Specified by:

getJournalIdentifier in class AbstractIncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

getManagedJournalIdentifier

public Collection<? extends JournalIdentifier> getManagedJournalIdentifier()

Description copied from interface: IncrementalSyncCleaner

Return all Journal Entry names which is managed by this service including all deleted Subscription

Specified by:

getManagedJournalIdentifier in interface IncrementalSyncCleaner

Returns:

handleEventForSubscription

public <E> void handleEventForSubscription(E event,
 Consumer<JournalIdentifier> processor)

Description copied from interface: IncrementalSyncService

Based on input event this method will find a corresponding subscription which would like to handle it. Then will trigger the call back to handle that

Specified by:

handleEventForSubscription in interface IncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

Overrides:

handleEventForSubscription in class AbstractIncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

Type Parameters:

E - an event

getEventsBatchLimit

public int getEventsBatchLimit()

Description copied from interface: IncrementalSyncService

Get max size of the events batch, that can be handled by the incremental sync service

Specified by:

getEventsBatchLimit in interface IncrementalSyncService<ContentSubscriptionSpec,ContentManagementIncSyncModel>

Returns:

max size of the events batch, that can be handled by the incremental sync service