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, incrementalSyncDataFetcher, journalService, logger, permissionManager, subscriptionJournalStateStore

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected JournalIdentifier	getJournalIdentifier()
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)
<T> void	handleEventForSubscription(T event, Consumer<JournalIdentifier> processor)	Based on input event this method will find a corresponding subscription which would like to handle it.

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

cleanObsoleteData, cleanUpSubscriptions, getAvailableSubscriptions, isSubscriptionActive, processEvents, subscribe, unsubscribe, verifyAdminUser

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, isSubscriptionActive, processEvents, subscribe, 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)

Method Details

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 JournalIdentifier getJournalIdentifier()

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 <T> void handleEventForSubscription(T 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:

T - an event