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

java.lang.String getTopic()

getMinReplKey

long getMinReplKey()

getMaxReplKey

long getMaxReplKey()

getTransactionSeq

long getTransactionSeq()

getStatus

java.lang.String getStatus()

getSqlResponse

java.lang.String getSqlResponse()

toggleActive

boolean toggleActive()
                     throws java.lang.Exception

Throws:

java.lang.Exception

cancelInitialUpdate

void cancelInitialUpdate()
                         throws java.lang.Exception

Throws:

java.lang.Exception

clearQueue

void clearQueue()
                throws java.lang.Exception

Throws:

java.lang.Exception

removeQueueEntries

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

Throws:

java.lang.Exception

kill

void kill()
          throws java.lang.Exception

Throws:

java.lang.Exception

reInitiateReplication

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

Throws:

java.lang.Exception

getReplPrefix

java.lang.String getReplPrefix()

getReplPrefixGroup

java.lang.String getReplPrefixGroup()

getVersion

java.lang.String getVersion()

isActive

boolean isActive()

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

getQueueEntries

long getQueueEntries()

isConnected

boolean isConnected()

getSessionName

java.lang.String getSessionName()

getLastMessage

java.lang.String getLastMessage()

dumpEntries

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

dumpFirstEntry

java.lang.String dumpFirstEntry()

getConnection

java.lang.String getConnection()

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

Returns:

isCascading

boolean isCascading()

getCascadedSessionName

java.lang.String getCascadedSessionName()

getCascadedQueueEntries

long getCascadedQueueEntries()

getCascadedTransactionSeq

long getCascadedTransactionSeq()

getCascadedStatus

java.lang.String getCascadedStatus()

isCascadedActive

boolean isCascadedActive()

isCascadedConnected

boolean isCascadedConnected()

getCascadedVersion

java.lang.String getCascadedVersion()

getMasterConnection

java.lang.String getMasterConnection()

getCascadedConnection

java.lang.String getCascadedConnection()

getCascadedMasterConnection

java.lang.String getCascadedMasterConnection()

setCountSingleMsg

void setCountSingleMsg(boolean countSingleMsg)

isCountSingleMsg

boolean isCountSingleMsg()

getMaxNumOfEntries

int getMaxNumOfEntries()

setMaxNumOfEntries

void setMaxNumOfEntries(int maxNumOfEntries)