org.xmlBlaster.contrib.filewatcher
Class Publisher.ReplSource
java.lang.Object
org.xmlBlaster.contrib.filewatcher.Publisher.ReplSource
- All Implemented Interfaces:
- I_ReplSource
- Enclosing class:
- Publisher
public class Publisher.ReplSource
- extends java.lang.Object
- implements I_ReplSource
Method Summary |
void |
cancelUpdate(java.lang.String slaveName)
|
void |
collectInitialUpdate()
|
byte[] |
executeStatement(java.lang.String sql,
long maxResponseEntries,
boolean isHighPrio,
boolean isMaster,
java.lang.String sqlTopic,
java.lang.String statementId)
|
java.lang.String |
getTopic()
|
void |
initialUpdate(java.lang.String topic,
java.lang.String address,
java.lang.String slaveName,
java.lang.String version,
java.lang.String location,
boolean onlyRegister)
|
void |
recreateTriggers()
|
void |
setEngine(ReplSourceEngine engine)
|
void |
startInitialUpdateBatch()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
preparedUpdates
private java.util.Map preparedUpdates
collectInitialUpdates
private boolean collectInitialUpdates
engine
private ReplSourceEngine engine
info
private I_Info info
oid
private java.lang.String oid
Publisher.ReplSource
public Publisher.ReplSource(I_Info info,
java.lang.String oid)
setEngine
public void setEngine(ReplSourceEngine engine)
cancelUpdate
public void cancelUpdate(java.lang.String slaveName)
- Specified by:
cancelUpdate
in interface I_ReplSource
collectInitialUpdate
public void collectInitialUpdate()
throws java.lang.Exception
- Specified by:
collectInitialUpdate
in interface I_ReplSource
- Throws:
java.lang.Exception
executeStatement
public byte[] executeStatement(java.lang.String sql,
long maxResponseEntries,
boolean isHighPrio,
boolean isMaster,
java.lang.String sqlTopic,
java.lang.String statementId)
throws java.lang.Exception
- Specified by:
executeStatement
in interface I_ReplSource
- Throws:
java.lang.Exception
initialUpdate
public void initialUpdate(java.lang.String topic,
java.lang.String address,
java.lang.String slaveName,
java.lang.String version,
java.lang.String location,
boolean onlyRegister)
throws java.lang.Exception
- Specified by:
initialUpdate
in interface I_ReplSource
- Throws:
java.lang.Exception
recreateTriggers
public void recreateTriggers()
throws java.lang.Exception
- Specified by:
recreateTriggers
in interface I_ReplSource
- Throws:
java.lang.Exception
startInitialUpdateBatch
public void startInitialUpdateBatch()
throws java.lang.Exception
- Specified by:
startInitialUpdateBatch
in interface I_ReplSource
- Throws:
java.lang.Exception
getTopic
public java.lang.String getTopic()
- Specified by:
getTopic
in interface I_ReplSource
Copyright © 1999-2014 The xmlBlaster.org contributers.