public class ReplicationBehavior
extends java.lang.Object
implements java.lang.AutoCloseable
Constructor and Description |
---|
ReplicationBehavior(DocumentStore documentStore) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected void |
waitForReplicationFromServer(java.lang.String url,
java.lang.String database,
Etag etag,
CancellationTokenSource.CancellationToken cancellationToken) |
int |
waitSync() |
int |
waitSync(Etag etag,
java.lang.Long timeout,
java.lang.String database,
int replicas) |
public ReplicationBehavior(DocumentStore documentStore)
public int waitSync() throws java.util.concurrent.TimeoutException
java.util.concurrent.TimeoutException
public int waitSync(Etag etag, java.lang.Long timeout, java.lang.String database, int replicas) throws java.util.concurrent.TimeoutException
java.util.concurrent.TimeoutException
protected void waitForReplicationFromServer(java.lang.String url, java.lang.String database, Etag etag, CancellationTokenSource.CancellationToken cancellationToken) throws java.lang.InterruptedException
java.lang.InterruptedException
public void close() throws java.lang.Exception
close
in interface java.lang.AutoCloseable
java.lang.Exception
Copyright © 2014. All Rights Reserved.