Class ReplicationStateInfo


  • public class ReplicationStateInfo
    extends java.lang.Object
    • 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)