xmlBlaster 2.2.0 API

org.xmlBlaster.contrib.filewatcher
Class Publisher.ReplSource

java.lang.Object
  extended by 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


Field Summary
private  boolean collectInitialUpdates
           
private  ReplSourceEngine engine
           
private  I_Info info
           
private  java.lang.String oid
           
private  java.util.Map preparedUpdates
           
 
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
 

Field Detail

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
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

xmlBlaster 2.2.0 API

Copyright © 1999-2014 The xmlBlaster.org contributers.