public class PointConsistencyPolicy extends java.lang.Object implements ReplicaConsistencyPolicy
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
NAME
The name:"PointConsistencyPolicy" associated with this policy.
|
Constructor and Description |
---|
PointConsistencyPolicy(VLSN targetVLSN) |
PointConsistencyPolicy(VLSN targetVLSN,
long timeout,
java.util.concurrent.TimeUnit timeoutUnit) |
Modifier and Type | Method and Description |
---|---|
void |
ensureConsistency(EnvironmentImpl replicatorImpl)
Ensures that the replica has replayed the replication stream to the
point identified by the commit token.
|
boolean |
equals(java.lang.Object obj) |
java.lang.String |
getName()
Returns the name:"PointConsistencyPolicy", associated with this policy.
|
long |
getTimeout(java.util.concurrent.TimeUnit unit)
The timeout associated with the consistency policy.
|
int |
hashCode() |
java.lang.String |
toString() |
public static final java.lang.String NAME
public PointConsistencyPolicy(VLSN targetVLSN)
public PointConsistencyPolicy(VLSN targetVLSN, long timeout, java.util.concurrent.TimeUnit timeoutUnit)
public java.lang.String getName()
getName
in interface ReplicaConsistencyPolicy
NAME
public void ensureConsistency(EnvironmentImpl replicatorImpl) throws java.lang.InterruptedException, ReplicaConsistencyException, DatabaseException
ensureConsistency
in interface ReplicaConsistencyPolicy
replicatorImpl
- identifies the replicated environment that must meet
this consistency requirement.java.lang.InterruptedException
ReplicaConsistencyException
DatabaseException
public long getTimeout(java.util.concurrent.TimeUnit unit)
ReplicaConsistencyPolicy
ReplicaConsistencyException
is thrown by Environment.beginTransaction(com.sleepycat.je.Transaction, com.sleepycat.je.TransactionConfig)
.getTimeout
in interface ReplicaConsistencyPolicy
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object
Copyright (c) 2004-2012 Oracle. All rights reserved.