org.xmlBlaster.contrib.replication
Interface I_ReplSource

All Known Implementing Classes:

InitialUpdater, Publisher.ReplSource

public interface 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 replTopic, java.lang.String replManagerAddress, java.lang.String slaveName, java.lang.String requestedVersion, java.lang.String initialFilesLocation, boolean onlyRegister)
void	recreateTriggers()
void	startInitialUpdateBatch()

Method Detail

getTopic

public java.lang.String getTopic()

initialUpdate

public void initialUpdate(java.lang.String replTopic,
                          java.lang.String replManagerAddress,
                          java.lang.String slaveName,
                          java.lang.String requestedVersion,
                          java.lang.String initialFilesLocation,
                          boolean onlyRegister)
                   throws java.lang.Exception

Throws:

java.lang.Exception

cancelUpdate

public void cancelUpdate(java.lang.String slaveName)

recreateTriggers

public void recreateTriggers()
                      throws java.lang.Exception

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

Throws:

java.lang.Exception

startInitialUpdateBatch

public void startInitialUpdateBatch()
                             throws java.lang.Exception

Throws:

java.lang.Exception

collectInitialUpdate

public void collectInitialUpdate()
                          throws java.lang.Exception

Throws:

java.lang.Exception