net.handle.hdllib

Class ReplicationStateInfo

java.lang.Object

net.handle.hdllib.ReplicationStateInfo

public class ReplicationStateInfo
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	LAST_TIMESTAMP
static java.lang.String	LAST_TXN_ID

Constructor Summary

Constructors

Constructor and Description
ReplicationStateInfo()

Method Summary

Modifier and Type	Method and Description
static ReplicationStateInfo	fromStreamTable(net.cnri.util.StreamTable replicationConfig, java.lang.String ownName)
long	getLastTimestamp(java.lang.String name)
long	getLastTxnId(java.lang.String name)
java.lang.String	getOwnName()
boolean	isQueueNameInOwnSite(java.lang.String queueName)
static boolean	isQueueNameInSiteNamed(java.lang.String queueName, java.lang.String ownName)
java.util.Set<java.lang.String>	keySet()
void	setLastTimestamp(java.lang.String name, long lastTimestamp)
void	setLastTxnId(java.lang.String name, long lastTxnId)
void	setOwnName(java.lang.String name)
static net.cnri.util.StreamTable	toStreamTable(ReplicationStateInfo replicationStateInfo)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LAST_TXN_ID

public static final java.lang.String LAST_TXN_ID

See Also:

Constant Field Values

LAST_TIMESTAMP

public static final java.lang.String LAST_TIMESTAMP

See Also:

Constant Field Values

Constructor Detail

ReplicationStateInfo

public ReplicationStateInfo()

Method Detail

keySet

public java.util.Set<java.lang.String> keySet()

getLastTxnId

public long getLastTxnId(java.lang.String name)

getLastTimestamp

public long getLastTimestamp(java.lang.String name)

setLastTxnId

public void setLastTxnId(java.lang.String name,
                         long lastTxnId)

setLastTimestamp

public void setLastTimestamp(java.lang.String name,
                             long lastTimestamp)

getOwnName

public java.lang.String getOwnName()

fromStreamTable

public static ReplicationStateInfo fromStreamTable(net.cnri.util.StreamTable replicationConfig,
                                                   java.lang.String ownName)

toStreamTable

public static net.cnri.util.StreamTable toStreamTable(ReplicationStateInfo replicationStateInfo)

setOwnName

public void setOwnName(java.lang.String name)

isQueueNameInOwnSite

public boolean isQueueNameInOwnSite(java.lang.String queueName)

isQueueNameInSiteNamed

public static boolean isQueueNameInSiteNamed(java.lang.String queueName,
                                             java.lang.String ownName)