org.jumpmind.symmetric.load
Class SyncTriggersRequiredFilter

java.lang.Object
  org.jumpmind.symmetric.load.SyncTriggersRequiredFilter

All Implemented Interfaces:

IExtensionPoint, IBatchListener, IDataLoaderFilter

public class SyncTriggersRequiredFilter
extends java.lang.Object
implements IDataLoaderFilter, IBatchListener

An out of the box filter that checks to see if the SymmetricDS trigger configuration has changed. If it has, it will synchronize triggers.

Constructor Summary

SyncTriggersRequiredFilter()

Method Summary

void	batchComplete(IDataLoader loader, IncomingBatchHistory history) This method is called after a batch has been successfully processed.
boolean	filterDelete(IDataLoaderContext context, java.lang.String[] keyValues)
boolean	filterInsert(IDataLoaderContext context, java.lang.String[] columnValues)
boolean	filterUpdate(IDataLoaderContext context, java.lang.String[] columnValues, java.lang.String[] keyValues)
boolean	isAutoRegister() Allow the plug-in implementation to specific whether the SymmetricDS runtime should auto register it or if it will register itself.
void	setBootstrapService(IBootstrapService bootstrapService)
void	setParameterService(IParameterService parameterService)
void	setTablePrefix(java.lang.String tablePrefix)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SyncTriggersRequiredFilter

public SyncTriggersRequiredFilter()

Method Detail

filterDelete

public boolean filterDelete(IDataLoaderContext context,
                            java.lang.String[] keyValues)

Specified by:

filterDelete in interface IDataLoaderFilter

Returns:

true if the row should be loaded. false if the filter has handled the row and it should be ignored.

filterInsert

public boolean filterInsert(IDataLoaderContext context,
                            java.lang.String[] columnValues)

Specified by:

filterInsert in interface IDataLoaderFilter

Returns:

true if the row should be loaded. false if the filter has handled the row and it should be ignored.

filterUpdate

public boolean filterUpdate(IDataLoaderContext context,
                            java.lang.String[] columnValues,
                            java.lang.String[] keyValues)

Specified by:

filterUpdate in interface IDataLoaderFilter

Returns:

true if the row should be loaded. false if the filter has handled the row and it should be ignored.

isAutoRegister

public boolean isAutoRegister()

Description copied from interface: IExtensionPoint

Allow the plug-in implementation to specific whether the SymmetricDS runtime should auto register it or if it will register itself.

Specified by:

isAutoRegister in interface IExtensionPoint

batchComplete

public void batchComplete(IDataLoader loader,
                          IncomingBatchHistory history)

Description copied from interface: IBatchListener

This method is called after a batch has been successfully processed. It is called in the scope of the transaction that controls the batch commit.

Specified by:

batchComplete in interface IBatchListener

setBootstrapService

public void setBootstrapService(IBootstrapService bootstrapService)

setParameterService

public void setParameterService(IParameterService parameterService)

setTablePrefix

public void setTablePrefix(java.lang.String tablePrefix)