Package com.ibm.di.osgi

Class ChangeDetectionConnectorDelegate

java.lang.Object

com.ibm.di.connector.Connector

com.ibm.di.osgi.ConnectorDelegate

com.ibm.di.osgi.ChangeDetectionConnectorDelegate

All Implemented Interfaces:

ChangelogInterface, ConnectorInterface, VersionInfoInterface

public class ChangeDetectionConnectorDelegate
extends ConnectorDelegate
implements ChangelogInterface

Note: This class is for internal usage only. Any dependency from the end-user will not be supported. Changes to this class will happen without a warning.

Since:

7.2

Field Summary

Fields inherited from class com.ibm.di.osgi.ConnectorDelegate

worker

Fields inherited from class com.ibm.di.connector.Connector

ALL_MODES, myLog, PROPERTY_MESSAGE, PROPERTY_READER, PROPERTY_WRITER

Fields inherited from interface com.ibm.di.connector.ChangelogInterface

CONN_PARAM_STATE_KEY_PERSISTENCE, PARAM_MERGE_BOTH_NOT_MERGED, PARAM_MERGE_CHANGELOG_AND_DATA, PARAM_MERGE_ONLY_CHANGED_DATA, PARAM_VAL_AFTER_READ, PARAM_VAL_END_OF_CYCLE, PARAM_VAL_MANUAL, SAVE_STATE_AFTER_READ, SAVE_STATE_END_OF_CYCLE, SAVE_STATE_MANUAL

Constructor Summary

Constructors

Constructor	Description
ChangeDetectionConnectorDelegate()
ChangeDetectionConnectorDelegate(java.lang.String id)

Method Summary

Modifier and Type	Method	Description
java.lang.Object	getStateKeyObject()	Retrieves state key.
int	getStateKeySaveMethod()	Retrieves the method for storing StateKey.
void	saveStateKey()	Stores the USN values for the next synchronization.

Methods inherited from class com.ibm.di.osgi.ConnectorDelegate

addFindEntry, clearFindEntries, clone, debug, debugMode, deleteEntry, equals, findEntry, findEntry, getBoolean, getConfiguration, getContext, getDelegate, getFindEntryCount, getFirstFindEntry, getLog, getMaxDuplicateEntries, getModes, getModes, getName, getNextClient, getNextEntry, getNextFindEntry, getParam, getParser, getProperty, getPushbackEntry, getRawConnectorConfiguration, getRSInterface, getUI, getVersion, hasConfigValue, hashCode, hasParser, initialize, initParser, isDeltaSupported, isExceptionFatal, isIOException, logError, logmsg, modEntry, modEntry, pushback, putEntry, queryOperations, queryReply, querySchema, queryTables, reconnect, reconnect, registerScriptBeans, replyEntry, selectEntries, setConfiguration, setContext, setCurrent, setDebugMode, setId, setLog, setMaxDuplicateEntries, setModes, setModes, setName, setParam, setParser, setProperty, setRSInterface, terminate, terminateServer, toString

Methods inherited from class com.ibm.di.connector.Connector

allModes, extractExceptionInformation, getClassInstance

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ChangeDetectionConnectorDelegate

public ChangeDetectionConnectorDelegate()

ChangeDetectionConnectorDelegate

public ChangeDetectionConnectorDelegate(java.lang.String id)
                                 throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getStateKeyObject

public java.lang.Object getStateKeyObject()
                                   throws java.lang.Exception

Description copied from interface: ChangelogInterface

Retrieves state key.

Specified by:

getStateKeyObject in interface ChangelogInterface

Returns:

the StateKey, wrapped in some kind of object.

Throws:

java.lang.Exception - if an error occurs.

getStateKeySaveMethod

public int getStateKeySaveMethod()
                          throws java.lang.Exception

Description copied from interface: ChangelogInterface

Retrieves the method for storing StateKey.

Specified by:

getStateKeySaveMethod in interface ChangelogInterface

Returns:

the identifier of the method used for storing the StateKey in the TDI Store.

Throws:

java.lang.Exception - - never

See Also:

ChangelogInterface.SAVE_STATE_AFTER_READ, ChangelogInterface.SAVE_STATE_END_OF_CYCLE, ChangelogInterface.SAVE_STATE_MANUAL

saveStateKey

public void saveStateKey()
                  throws java.lang.Exception

Description copied from interface: ChangelogInterface

Stores the USN values for the next synchronization. This method will skip the storing of the StateKey if the StateKey save method is set to ChangelogInterface.SAVE_STATE_AFTER_READ

Specified by:

saveStateKey in interface ChangelogInterface

Throws:

java.lang.Exception - - never