org.xmlBlaster.contrib.replication
Interface ReplSlaveMBean

All Known Implementing Classes:

ReplSlave

public interface ReplSlaveMBean

Method Summary

void	cancelInitialUpdate()
void	clearQueue()
java.lang.String	dumpEntries(int maxNum, long maxSize, java.lang.String fileName)
java.lang.String	dumpFirstEntry()
java.lang.String	getCascadedConnection()
java.lang.String	getCascadedMasterConnection()
long	getCascadedQueueEntries()
java.lang.String	getCascadedSessionName()
java.lang.String	getCascadedStatus()
long	getCascadedTransactionSeq()
java.lang.String	getCascadedVersion()
java.lang.String	getConnection() Returns a string telling in which state the connection is.
java.lang.String	getLastMessage()
java.lang.String	getMasterConnection()
int	getMaxNumOfEntries()
long	getMaxReplKey()
long	getMinReplKey()
long	getQueueEntries()
java.lang.String	getReplPrefix()
java.lang.String	getReplPrefixGroup()
java.lang.String	getSessionName()
java.lang.String	getSqlResponse()
java.lang.String	getStatus()
java.lang.String	getTopic()
long	getTransactionSeq()
java.lang.String	getVersion()
boolean	isActive() These go to the backend (are invoked asynchronously to avoid blocking)
boolean	isCascadedActive()
boolean	isCascadedConnected()
boolean	isCascading()
boolean	isConnected()
boolean	isCountSingleMsg()
void	kill()
java.lang.String	reInitiateReplication()
long	removeQueueEntries(long entries)
void	setCountSingleMsg(boolean countSingleMsg)
void	setMaxNumOfEntries(int maxNumOfEntries)
boolean	toggleActive()

Method Detail

getTopic

public java.lang.String getTopic()

getMinReplKey

public long getMinReplKey()

getMaxReplKey

public long getMaxReplKey()

getTransactionSeq

public long getTransactionSeq()

getStatus

public java.lang.String getStatus()

getSqlResponse

public java.lang.String getSqlResponse()

toggleActive

public boolean toggleActive()
                     throws java.lang.Exception

Throws:

java.lang.Exception

cancelInitialUpdate

public void cancelInitialUpdate()
                         throws java.lang.Exception

Throws:

java.lang.Exception

clearQueue

public void clearQueue()
                throws java.lang.Exception

Throws:

java.lang.Exception

removeQueueEntries

public long removeQueueEntries(long entries)
                        throws java.lang.Exception

Throws:

java.lang.Exception

kill

public void kill()
          throws java.lang.Exception

Throws:

java.lang.Exception

reInitiateReplication

public java.lang.String reInitiateReplication()
                                       throws java.lang.Exception

Throws:

java.lang.Exception

getReplPrefix

public java.lang.String getReplPrefix()

getReplPrefixGroup

public java.lang.String getReplPrefixGroup()

getVersion

public java.lang.String getVersion()

isActive

public boolean isActive()

These go to the backend (are invoked asynchronously to avoid blocking)

getQueueEntries

public long getQueueEntries()

isConnected

public boolean isConnected()

getSessionName

public java.lang.String getSessionName()

getLastMessage

public java.lang.String getLastMessage()

dumpEntries

public java.lang.String dumpEntries(int maxNum,
                                    long maxSize,
                                    java.lang.String fileName)

dumpFirstEntry

public java.lang.String dumpFirstEntry()

getConnection

public java.lang.String getConnection()

Returns a string telling in which state the connection is. It can be stalled, connected or disconnected.

Returns:

isCascading

public boolean isCascading()

getCascadedSessionName

public java.lang.String getCascadedSessionName()

getCascadedQueueEntries

public long getCascadedQueueEntries()

getCascadedTransactionSeq

public long getCascadedTransactionSeq()

getCascadedStatus

public java.lang.String getCascadedStatus()

isCascadedActive

public boolean isCascadedActive()

isCascadedConnected

public boolean isCascadedConnected()

getCascadedVersion

public java.lang.String getCascadedVersion()

getMasterConnection

public java.lang.String getMasterConnection()

getCascadedConnection

public java.lang.String getCascadedConnection()

getCascadedMasterConnection

public java.lang.String getCascadedMasterConnection()

setCountSingleMsg

public void setCountSingleMsg(boolean countSingleMsg)

isCountSingleMsg

public boolean isCountSingleMsg()

getMaxNumOfEntries

public int getMaxNumOfEntries()

setMaxNumOfEntries

public void setMaxNumOfEntries(int maxNumOfEntries)