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

Class UserManagementIncrementalSyncServiceImpl

java.lang.Object

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

com.atlassian.confluence.internal.api.impl.service.incrementalsync.usermanagement.UserManagementIncrementalSyncServiceImpl

All Implemented Interfaces:

IncrementalSyncCleaner, IncrementalSyncService<SimpleSubscriptionSpec,UserManagementInSyncModel>, UserManagementIncrementalSyncService

public class UserManagementIncrementalSyncServiceImpl
extends AbstractIncrementalSyncService<SimpleSubscriptionSpec,UserManagementInSyncModel>
implements UserManagementIncrementalSyncService

Default implementation of IncrementalSyncService for User Management

Since:

9.3.0

Field Summary

Fields

Modifier and Type	Field	Description
static final String	USER_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
UserManagementIncrementalSyncServiceImpl(JournalServiceInternal journalService, SubscriptionJournalStateStore subscriptionJournalStateStore, com.atlassian.core.util.Clock clock, PermissionManager permissionManager, IncrementalSyncDataFetcher<UserManagementInSyncModel> 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

USER_MANAGEMENT_INC_SYNC_JOURNAL_NAME

public static final String USER_MANAGEMENT_INC_SYNC_JOURNAL_NAME

See Also:

• Constant Field Values

Constructor Details

UserManagementIncrementalSyncServiceImpl

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

Method Details

getSubscriptionData

protected String getSubscriptionData(SimpleSubscriptionSpec spec)

Specified by:

getSubscriptionData in class AbstractIncrementalSyncService<SimpleSubscriptionSpec,UserManagementInSyncModel>

getJournalName

protected String getJournalName()

Specified by:

getJournalName in class AbstractIncrementalSyncService<SimpleSubscriptionSpec,UserManagementInSyncModel>

getJournalIdentifier

protected MultiSubscriptionPerJournalIdentifier getJournalIdentifier(long subscriptionId)

Specified by:

getJournalIdentifier in class AbstractIncrementalSyncService<SimpleSubscriptionSpec,UserManagementInSyncModel>

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,UserManagementInSyncModel>

Returns:

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