public class ReplicationBehavior extends Object implements CleanCloseable
Constructor and Description |
---|
ReplicationBehavior(DocumentStore documentStore) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected void |
waitForReplicationFromServer(String url,
String sourceUrl,
String sourceDbId,
Etag etag,
ReplicatedEtagInfo[] latestEtags,
int index,
CancellationTokenSource.CancellationToken cancellationToken) |
int |
waitSync() |
int |
waitSync(Etag etag,
Long timeout,
String database,
int replicas) |
public ReplicationBehavior(DocumentStore documentStore)
public int waitSync() throws TimeoutException
TimeoutException
public int waitSync(Etag etag, Long timeout, String database, int replicas) throws TimeoutException
TimeoutException
protected void waitForReplicationFromServer(String url, String sourceUrl, String sourceDbId, Etag etag, ReplicatedEtagInfo[] latestEtags, int index, CancellationTokenSource.CancellationToken cancellationToken) throws InterruptedException
InterruptedException
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface CleanCloseable
Copyright © 2016. All Rights Reserved.