public class SynchronisationStatusManagerImpl extends Object implements InternalSynchronisationStatusManager
Constructor and Description |
---|
SynchronisationStatusManagerImpl(DirectorySynchronisationInformationStore store,
com.atlassian.event.api.EventPublisher eventPublisher,
DirectoryDao directoryDao,
Clock clock,
DirectoryPollerManager pollerManager,
com.atlassian.beehive.ClusterLockService lockService,
DirectorySynchronisationTokenStore directorySynchronisationTokenStore) |
Modifier and Type | Method and Description |
---|---|
void |
clearSynchronisationTokenForDirectory(long directoryId)
Clears the synchronisation token for the given directory
|
DirectorySynchronisationInformation |
getDirectorySynchronisationInformation(Directory directory)
Returns directory synchronisation information.
|
DirectorySynchronisationInformation |
getDirectorySynchronisationInformation(long directoryId)
Returns directory synchronisation information.
|
String |
getLastSynchronisationTokenForDirectory(long directoryId)
Returns the last stored synchronisation token for the directory
|
void |
handleEvent(XMLRestoreStartedEvent event) |
void |
removeStatusesForDirectory(long directoryId)
Removes statuses for the given directory
|
int |
rescheduleStalledSynchronisations()
Attempts to find synchronisations started by nodes that have terminated, and reschedule them.
|
void |
storeSynchronisationTokenForDirectory(long directoryId,
String synchronisationToken)
Store a new synchronisation token for the given directory.
|
void |
syncFinished(long directoryId)
Notify that directory synchronisation has finished.
|
void |
syncFinished(long directoryId,
SynchronisationStatusKey statusKey,
List<Serializable> parameters)
Notify that directory synchronisation has finished.
|
void |
syncStarted(Directory directory)
Notify that directory synchronisation has started.
|
void |
syncStatus(long directoryId,
String key,
Serializable... parameters)
Notify that directory synchronisation status has changed.
|
void |
syncStatus(long directoryId,
SynchronisationStatusKey statusKey,
List<Serializable> parameters)
Notify that directory synchronisation status has changed
|
public SynchronisationStatusManagerImpl(DirectorySynchronisationInformationStore store, com.atlassian.event.api.EventPublisher eventPublisher, DirectoryDao directoryDao, Clock clock, DirectoryPollerManager pollerManager, com.atlassian.beehive.ClusterLockService lockService, DirectorySynchronisationTokenStore directorySynchronisationTokenStore)
public void syncStarted(Directory directory)
SynchronisationStatusManager
syncStarted
in interface SynchronisationStatusManager
directory
- directorypublic void syncStatus(long directoryId, String key, Serializable... parameters)
SynchronisationStatusManager
syncStatus
in interface SynchronisationStatusManager
directoryId
- directory idkey
- synchronisation status message keyparameters
- synchronisation status message parameterspublic void syncStatus(long directoryId, SynchronisationStatusKey statusKey, List<Serializable> parameters)
SynchronisationStatusManager
syncStatus
in interface SynchronisationStatusManager
directoryId
- directory idstatusKey
- synchronisation status message keyparameters
- synchronisation status message parameterspublic void syncFinished(long directoryId)
SynchronisationStatusManager
syncFinished
in interface SynchronisationStatusManager
directoryId
- directory idpublic void syncFinished(long directoryId, SynchronisationStatusKey statusKey, List<Serializable> parameters)
SynchronisationStatusManager
syncFinished
in interface SynchronisationStatusManager
directoryId
- directory idstatusKey
- synchronisation statusparameters
- parameters for statusKeypublic DirectorySynchronisationInformation getDirectorySynchronisationInformation(Directory directory)
SynchronisationStatusManager
getDirectorySynchronisationInformation
in interface SynchronisationStatusManager
directory
- directory to retrieve information from@Transactional public DirectorySynchronisationInformation getDirectorySynchronisationInformation(long directoryId) throws DirectoryNotFoundException
SynchronisationStatusManager
getDirectorySynchronisationInformation
in interface SynchronisationStatusManager
directoryId
- directory id to retrieve information fromDirectoryNotFoundException
@Transactional public String getLastSynchronisationTokenForDirectory(long directoryId)
SynchronisationStatusManager
getLastSynchronisationTokenForDirectory
in interface SynchronisationStatusManager
directoryId
- the id of the directory@Transactional public void storeSynchronisationTokenForDirectory(long directoryId, String synchronisationToken)
SynchronisationStatusManager
storeSynchronisationTokenForDirectory
in interface SynchronisationStatusManager
directoryId
- the id of the directorysynchronisationToken
- the new token to storepublic void removeStatusesForDirectory(long directoryId)
SynchronisationStatusManager
removeStatusesForDirectory
in interface SynchronisationStatusManager
directoryId
- directory idpublic int rescheduleStalledSynchronisations()
InternalSynchronisationStatusManager
rescheduleStalledSynchronisations
in interface InternalSynchronisationStatusManager
for non-clustered handling
@Transactional public void clearSynchronisationTokenForDirectory(long directoryId)
SynchronisationStatusManager
clearSynchronisationTokenForDirectory
in interface SynchronisationStatusManager
directoryId
- directory id@EventListener public void handleEvent(XMLRestoreStartedEvent event)
Copyright © 2018 Atlassian. All rights reserved.