|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface I_ReplSlave
I_ReplSlave
Field Summary | |
---|---|
static java.lang.String |
CASCADED_REPL_PREFIX
|
static java.lang.String |
CASCADED_REPL_SLAVE
|
static java.lang.String |
DBWATCHER_SESSION_NAME
|
static int |
STATUS_INCONSISTENT
|
static int |
STATUS_INITIAL
|
static int |
STATUS_NORMAL
|
static int |
STATUS_TRANSITION
|
static int |
STATUS_UNCONFIGURED
|
Method Summary | |
---|---|
void |
cancelInitialUpdate(boolean async)
|
java.util.ArrayList |
check(java.util.List<I_Entry> pushEntries,
I_Queue queue)
|
void |
checkStatus()
Checks on the backend data which has to be displayed on the MBean. |
int |
getMaxNumOfEntries()
|
java.lang.String |
getReplPrefix()
|
java.lang.String |
getSessionName()
|
java.lang.String |
getStatus()
|
int |
getStatusAsInt()
|
void |
handleException(java.lang.Throwable ex)
Pauses the dispatcher. |
void |
incrementPtPEntries(long numOfTransactions)
Increments the amount of entries in the ptp counter queue |
void |
onDeadLetter(java.util.Map qosClientProperties)
Invoked by the ReplManagerPlugin when a deadMessage is published because an error |
void |
postCheck(MsgUnit[] processedEntries)
|
void |
prepareForRequest(I_Info individualInfo)
3 |
void |
reactivateDestination(long minReplKey,
long maxReplKey)
6 This is received by the DbWatcher jvm. |
boolean |
reInitiate(I_Info info)
|
void |
requestInitialData(java.lang.String dbWatcherSessionId,
boolean onlyRegister)
|
boolean |
run(I_Info individualInfo,
java.lang.String dbWatcherSessionId,
java.lang.String cascadeReplPrefix,
java.lang.String cascadeSlaveSessionName,
boolean onlyRegister)
Starts a replication |
boolean |
setDispatcher(boolean status)
|
boolean |
setDispatcher(boolean status,
boolean doPersist)
|
void |
setSqlResponse(java.lang.String sqlResponse)
|
Methods inherited from interface org.xmlBlaster.contrib.I_ContribPlugin |
---|
getUsedPropertyKeys, init, shutdown |
Field Detail |
---|
static final int STATUS_UNCONFIGURED
static final int STATUS_INITIAL
static final int STATUS_TRANSITION
static final int STATUS_NORMAL
static final int STATUS_INCONSISTENT
static final java.lang.String DBWATCHER_SESSION_NAME
static final java.lang.String CASCADED_REPL_SLAVE
static final java.lang.String CASCADED_REPL_PREFIX
Method Detail |
---|
boolean run(I_Info individualInfo, java.lang.String dbWatcherSessionId, java.lang.String cascadeReplPrefix, java.lang.String cascadeSlaveSessionName, boolean onlyRegister) throws java.lang.Exception
individualInfo
- dbWatcherSessionId
- cascadeReplPrefix
- can be nullcascadeSlaveSessionName
- can be nullonlyRegister
- true, then it only registers the initial update (it will wait until an start comes)
java.lang.Exception
void prepareForRequest(I_Info individualInfo) throws java.lang.Exception
java.lang.Exception
java.lang.String getStatus()
java.lang.String getReplPrefix()
boolean reInitiate(I_Info info) throws java.lang.Exception
java.lang.Exception
void requestInitialData(java.lang.String dbWatcherSessionId, boolean onlyRegister) throws java.lang.Exception
java.lang.Exception
void reactivateDestination(long minReplKey, long maxReplKey) throws java.lang.Exception
minReplKey
- the replication key taken before initiating the db side
operation on the master.maxReplKey
- the replication key taken after initiating the db side
operation on the master.
java.lang.Exception
java.util.ArrayList check(java.util.List<I_Entry> pushEntries, I_Queue queue) throws java.lang.Exception
java.lang.Exception
void postCheck(MsgUnit[] processedEntries) throws java.lang.Exception
java.lang.Exception
void setSqlResponse(java.lang.String sqlResponse)
sqlResponse
- The sqlResponse to set.void handleException(java.lang.Throwable ex)
void checkStatus()
int getStatusAsInt()
java.lang.String getSessionName()
boolean setDispatcher(boolean status)
boolean setDispatcher(boolean status, boolean doPersist) throws java.lang.Exception
java.lang.Exception
void incrementPtPEntries(long numOfTransactions)
numOfTransactions
- int getMaxNumOfEntries()
void onDeadLetter(java.util.Map qosClientProperties)
void cancelInitialUpdate(boolean async) throws java.lang.Exception
java.lang.Exception
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |