Package net.handle.hdllib

Class ReplicationStateInfo

java.lang.Object

net.handle.hdllib.ReplicationStateInfo

public class ReplicationStateInfo
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	LAST_TIMESTAMP
static final String	LAST_TXN_ID

Constructor Summary

Constructors

Constructor	Description
ReplicationStateInfo()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

LAST_TXN_ID

public static final String LAST_TXN_ID

See Also:

• Constant Field Values

LAST_TIMESTAMP

public static final String LAST_TIMESTAMP

See Also:

• Constant Field Values

Constructor Details

ReplicationStateInfo

public ReplicationStateInfo()

Method Details

keySet

public Set<String> keySet()

getLastTxnId

public long getLastTxnId(String name)

getLastTimestamp

public long getLastTimestamp(String name)

setLastTxnId

public void setLastTxnId(String name,
 long lastTxnId)

setLastTimestamp

public void setLastTimestamp(String name,
 long lastTimestamp)

getOwnName

public String getOwnName()

fromStreamTable

public static ReplicationStateInfo fromStreamTable(StreamTable replicationConfig,
 String ownName)

toStreamTable

public static StreamTable toStreamTable(ReplicationStateInfo replicationStateInfo)

setOwnName

public void setOwnName(String name)

isQueueNameInOwnSite

public boolean isQueueNameInOwnSite(String queueName)

isQueueNameInSiteNamed

public static boolean isQueueNameInSiteNamed(String queueName,
 String ownName)