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

Constructor Summary

Publisher.ReplSource(I_Info info, java.lang.String oid)

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

Constructor Detail

Publisher.ReplSource

public Publisher.ReplSource(I_Info info,
                            java.lang.String oid)

Method Detail

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