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

Class GlobalPermissionManagementIncrementalSyncServiceImpl

java.lang.Object

com.atlassian.confluence.internal.api.impl.service.incrementalsync.AbstractIncrementalSyncService<SimpleSubscriptionSpec,GlobalPermissionManagementIncSyncModel>

com.atlassian.confluence.internal.api.impl.service.incrementalsync.globalpermissionmanagement.GlobalPermissionManagementIncrementalSyncServiceImpl

All Implemented Interfaces:

GlobalPermissionManagementIncrementalSyncService, IncrementalSyncCleaner, IncrementalSyncService<SimpleSubscriptionSpec,GlobalPermissionManagementIncSyncModel>

public class GlobalPermissionManagementIncrementalSyncServiceImpl
extends AbstractIncrementalSyncService<SimpleSubscriptionSpec,GlobalPermissionManagementIncSyncModel>
implements GlobalPermissionManagementIncrementalSyncService

Service class for managing global permissions event related incremental sync operations

Since:

9.3.0

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PERMISSION_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
GlobalPermissionManagementIncrementalSyncServiceImpl(JournalServiceInternal journalService, SubscriptionJournalStateStore subscriptionJournalStateStore, com.atlassian.core.util.Clock clock, PermissionManager permissionManager, IncrementalSyncDataFetcher<GlobalPermissionManagementIncSyncModel> 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 MultiSubscriptionPerJournalIdentifier	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(SimpleSubscriptionSpec spec)

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

cleanObsoleteData, cleanUpSubscriptions, getAvailableSubscriptions, getMostRecentCursor, handleEventForSubscription, isSubscriptionActive, processEvents, subscribe, 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, handleEventForSubscription, isSubscriptionActive, processEvents, subscribe, unsubscribe

Field Details

PERMISSION_MANAGEMENT_INC_SYNC_JOURNAL_NAME

public static final String PERMISSION_MANAGEMENT_INC_SYNC_JOURNAL_NAME

See Also:

• Constant Field Values

Constructor Details

GlobalPermissionManagementIncrementalSyncServiceImpl

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

Method Details

getSubscriptionData

protected String getSubscriptionData(SimpleSubscriptionSpec spec)

Specified by:

getSubscriptionData in class AbstractIncrementalSyncService<SimpleSubscriptionSpec,GlobalPermissionManagementIncSyncModel>

getJournalName

protected String getJournalName()

Specified by:

getJournalName in class AbstractIncrementalSyncService<SimpleSubscriptionSpec,GlobalPermissionManagementIncSyncModel>

getJournalIdentifier

protected MultiSubscriptionPerJournalIdentifier getJournalIdentifier(long subscriptionId)

Specified by:

getJournalIdentifier in class AbstractIncrementalSyncService<SimpleSubscriptionSpec,GlobalPermissionManagementIncSyncModel>

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:

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<SimpleSubscriptionSpec,GlobalPermissionManagementIncSyncModel>

Returns:

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