@Internal public class ClusteredReplicationPauserManager extends Object implements ReplicationPauserManager
Constructor and Description |
---|
ClusteredReplicationPauserManager() |
Modifier and Type | Method and Description |
---|---|
boolean |
isReplicationPaused()
Checks if replication is paused for current thread
|
void |
pauseReplicationFor(Runnable codeWillNotTriggerCacheReplication,
String logContext)
Disables sending cache replication events for the time of running codeWillNotTriggerCacheReplication.
|
void |
start(String logContext)
Start pausing the replication context.
|
void |
stop(String logContext) |
public boolean isReplicationPaused()
ReplicationPauserManager
isReplicationPaused
in interface ReplicationPauserManager
public void pauseReplicationFor(Runnable codeWillNotTriggerCacheReplication, String logContext)
ReplicationPauserManager
pauseReplicationFor
in interface ReplicationPauserManager
codeWillNotTriggerCacheReplication
- - code to be run without cache replicationlogContext
- - log context to be able to understand the reason cache replication is pausedpublic void start(String logContext)
stop(String)
is called (in finally block) - if not this thread will stop replicate cache operations!public void stop(String logContext)
Copyright © 2002-2022 Atlassian. All Rights Reserved.