com.ibm.di.connector
Class ExchangeChangelogConnector

java.lang.Object
  com.ibm.di.connector.Connector
      com.ibm.di.connector.LDAPConnector
          com.ibm.di.connector.ExchangeChangelogConnector

All Implemented Interfaces:

ConnectorInterface, CheckpointRestartInterface, VersionInfoInterface

public class ExchangeChangelogConnector
extends LDAPConnector
implements ConnectorInterface, CheckpointRestartInterface

The class ExchangeChangelogConnector represents the Exchange 5.5 Directory Service Changelog Connector class that will be accessed by IBM Tivoli Directory Integrator. It extends the LDAP Connector class (LDAPConnector) and overrides some of its methods to implement Exchange-specific changelog functionality.

Field Summary

static String	ATTR_CHANGE_TYPE
static String	CHANGE_TYPE_ADD
static String	CHANGE_TYPE_DELETE
static String	CHANGE_TYPE_MODIFY
static String	EXCHANGE_ATTR_HIGHEST_COMMITTED_USN
static String	EXCHANGE_ATTR_IS_DELETED
static String	EXCHANGE_ATTR_USN_CHANGED
static String	EXCHANGE_ATTR_USN_CREATED
static String	PARAM_DELETED_ATTRIBUTE_VISIBLE
static String	PARAM_LDAP_SEARCH_BASE
static String	PARAM_SLEEP_INTERVAL
static String	PARAM_START_AT
static String	PARAM_TIMEOUT
static String	PARAM_USN_FILE_NAME
static String	PARAM_USN_STORE_PARAM_NAME
static String	PROP_CURRENT_USN_CHANGED
static String	PROP_CURRENT_USN_CREATED
static String	PROP_END_USN
static String	PROP_START_USN

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.server.CheckpointRestartInterface

RESTART_AFTER, RESTART_BEFORE, RESTART_IN

Constructor Summary

ExchangeChangelogConnector()
Calls the super constructor and assigns supported Connector modes.

Method Summary

Entry	getCheckpointInformation() Returns the state information for the connector.
protected int	getHighestCommittedUsn() Retrieves the highest committed USN from Exchange Directory Service.
Entry	getNextEntry() Retrieves the next "changed" object from Exchange Directory Service.
protected void	getStartUsnValues() Reads start USN values.
Entry	getUsnValues() Returns an Entry object containing the current USN synchronization values.
String	getVersion() Return version information
void	initialize(Object obj) Reads connector parameters' values and prepares LDAP search constraints.
boolean	isCheckpointRestartEnabled(int aMode) Components that support checkpoint/restart for a specific mode must return TRUE from this method.
protected Entry	packUsnValues() Returns an Entry containing the current Connector's USN values as properties.
void	prepareForRestart(ALState aState, Entry aRestartInfo, int aRestartPoint) Notifies the connector of a restart situation.
protected Entry	retrieveEntry(String aFilter) Retrieves an Entry from Exchange Directory Service based on the given filter.
void	selectEntries() Reads the initial USN values and sets necessary request controls.
void	setUsnValues(Entry aUsnEntry) Sets the Connector’s current USN synchronization values to the values specified in the "aUsnEntry" parameter.
protected void	storeUSNForNextSynch() Stores the USN values for the next synchronization.

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

addAttributeValue, at2entry, compare, deleteEntry, entry2at, findEntry, flagSet, getAttributeSyntax, getCurrentEntry, getLdapContext, getServerControls, getServerInfo, isDeltaSupported, isExceptionFatal, mapAttributeSyntax, modEntry, modEntry, moveEntry, putEntry, queryNamingContexts, queryObjectClassAttributes, querySchema, rebind, rebind, removeAllAttributeValues, removeAttributeValue, replaceAttributeValue, setADPassword, showServerInfo, supportsControl, supportsExtension, supportsPagedResults, supportsPersistantSearch, supportsSorting, supportsVirtualListView, terminate

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

addFindEntry, allModes, clearFindEntries, debug, debugMode, findEntry, getBoolean, getClassInstance, getConfiguration, getContext, getFindEntryCount, getFirstFindEntry, getLog, getMaxDuplicateEntries, getModes, getModes, getName, getNextClient, getNextFindEntry, getParam, getParser, getProperty, getPushbackEntry, getRawConnectorConfiguration, getRSInterface, hasConfigValue, hasParser, initParser, isIOException, logmsg, pushback, queryOperations, queryReply, queryTables, reconnect, reconnect, registerScriptBeans, replyEntry, setConfiguration, setContext, setCurrent, setLog, setMaxDuplicateEntries, setModes, setModes, setName, setParam, setParser, setProperty, setRSInterface, terminateServer

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ibm.di.connector.ConnectorInterface

deleteEntry, findEntry, getConfiguration, getContext, getFindEntryCount, getFirstFindEntry, getMaxDuplicateEntries, getName, getNextClient, getNextFindEntry, getParam, getPushbackEntry, getRawConnectorConfiguration, isDeltaSupported, isExceptionFatal, isIOException, modEntry, modEntry, pushback, putEntry, queryOperations, queryReply, querySchema, reconnect, registerScriptBeans, replyEntry, setConfiguration, setContext, setCurrent, setLog, setMaxDuplicateEntries, setName, setParam, setRSInterface, terminate, terminateServer

Field Detail

PARAM_LDAP_SEARCH_BASE

public static final String PARAM_LDAP_SEARCH_BASE

See Also:

Constant Field Values

PARAM_USN_FILE_NAME

public static final String PARAM_USN_FILE_NAME

See Also:

Constant Field Values

PARAM_USN_STORE_PARAM_NAME

public static final String PARAM_USN_STORE_PARAM_NAME

See Also:

Constant Field Values

PARAM_START_AT

public static final String PARAM_START_AT

See Also:

Constant Field Values

PARAM_DELETED_ATTRIBUTE_VISIBLE

public static final String PARAM_DELETED_ATTRIBUTE_VISIBLE

See Also:

Constant Field Values

PARAM_SLEEP_INTERVAL

public static final String PARAM_SLEEP_INTERVAL

See Also:

Constant Field Values

PARAM_TIMEOUT

public static final String PARAM_TIMEOUT

See Also:

Constant Field Values

ATTR_CHANGE_TYPE

public static final String ATTR_CHANGE_TYPE

See Also:

Constant Field Values

CHANGE_TYPE_ADD

public static final String CHANGE_TYPE_ADD

See Also:

Constant Field Values

CHANGE_TYPE_MODIFY

public static final String CHANGE_TYPE_MODIFY

See Also:

Constant Field Values

CHANGE_TYPE_DELETE

public static final String CHANGE_TYPE_DELETE

See Also:

Constant Field Values

EXCHANGE_ATTR_USN_CHANGED

public static final String EXCHANGE_ATTR_USN_CHANGED

See Also:

Constant Field Values

EXCHANGE_ATTR_USN_CREATED

public static final String EXCHANGE_ATTR_USN_CREATED

See Also:

Constant Field Values

EXCHANGE_ATTR_IS_DELETED

public static final String EXCHANGE_ATTR_IS_DELETED

See Also:

Constant Field Values

EXCHANGE_ATTR_HIGHEST_COMMITTED_USN

public static final String EXCHANGE_ATTR_HIGHEST_COMMITTED_USN

See Also:

Constant Field Values

PROP_START_USN

public static final String PROP_START_USN

See Also:

Constant Field Values

PROP_END_USN

public static final String PROP_END_USN

See Also:

Constant Field Values

PROP_CURRENT_USN_CREATED

public static final String PROP_CURRENT_USN_CREATED

See Also:

Constant Field Values

PROP_CURRENT_USN_CHANGED

public static final String PROP_CURRENT_USN_CHANGED

See Also:

Constant Field Values

Constructor Detail

ExchangeChangelogConnector

public ExchangeChangelogConnector()

Calls the super constructor and assigns supported Connector modes.

Method Detail

initialize

public void initialize(Object obj)
                throws Exception

Reads connector parameters' values and prepares LDAP search constraints.

Specified by:

initialize in interface ConnectorInterface

Overrides:

initialize in class LDAPConnector

Parameters:

obj - This parameter is usually null but can be any type of object the caller chooses to pass on. Normally the parameter is some kind of input stream or Reader object.

Throws:

Exception - If invalid Connector parameter values are supplied.

getStartUsnValues

protected void getStartUsnValues()
                          throws Exception

Reads start USN values. Sources for start USN values are checked in this order:

(1) Restart info is passed;

(2) File name parameter is specified - backward compatibility mode;

(3) Persistent parameter - if the specified parameter is not found in the store, the "Start at" value is used.

Throws:

Exception

selectEntries

public void selectEntries()
                   throws Exception

Reads the initial USN values and sets necessary request controls.

Specified by:

selectEntries in interface ConnectorInterface

Overrides:

selectEntries in class LDAPConnector

Throws:

Exception - Any Exception by the underlying library

getHighestCommittedUsn

protected int getHighestCommittedUsn()
                              throws Exception

Retrieves the highest committed USN from Exchange Directory Service.

Returns:

The Exchange Directory Service's "highestCommittedUsn" Attribute.

Throws:

Exception - If error occurs while retrieving the highest commited USN.

retrieveEntry

protected Entry retrieveEntry(String aFilter)
                       throws NamingException

Retrieves an Entry from Exchange Directory Service based on the given filter.

Parameters:

aFilter - The LDAP filter for retrieving the Entry.

Returns:

The first Entry that matched the filter; "null" if no Exchange Directory Service Entry matches the filter.

Throws:

NamingException - If error occurs while retrieving the Entry from Exchange Directory Service.

getNextEntry

public Entry getNextEntry()
                   throws Exception

Retrieves the next "changed" object from Exchange Directory Service.

Specified by:

getNextEntry in interface ConnectorInterface

Overrides:

getNextEntry in class LDAPConnector

Returns:

The next "changed" Entry object.

Throws:

Exception - If retrieving the next "changed" Entry fails.

See Also:

Connector.selectEntries()

packUsnValues

protected Entry packUsnValues()

Returns an Entry containing the current Connector's USN values as properties. Such Entries are used for storage in the persistent store.

storeUSNForNextSynch

protected void storeUSNForNextSynch()

Stores the USN values for the next synchronization.

isCheckpointRestartEnabled

public boolean isCheckpointRestartEnabled(int aMode)

Components that support checkpoint/restart for a specific mode must return TRUE from this method. If a restart has no meaning for mode then the connector should still return TRUE.

Specified by:

isCheckpointRestartEnabled in interface CheckpointRestartInterface

Parameters:

aMode - The mode the connector runs in

Returns:

true if checkpoint is supported in mode

See Also:

ServerConstants

getCheckpointInformation

public Entry getCheckpointInformation()
                               throws Exception

Returns the state information for the connector. If for some reason the connector decidies that a restart is impossible it must throw an exception. The method is called immediatly before any component methods are called. If there is no need to save any state information a null value should be returned. For eventhandlers this method is called by the dispatcher routine.

Specified by:

getCheckpointInformation in interface CheckpointRestartInterface

Returns:

The entry the connector needs to do a restart or null if that is not needed.

Throws:

Exception

prepareForRestart

public void prepareForRestart(ALState aState,
                              Entry aRestartInfo,
                              int aRestartPoint)
                       throws Exception

Notifies the connector of a restart situation. This method is called after the connector has been loaded and before any other method calls are made to the connector. If the connector decides it cannot restart it must throw an exception.

Specified by:

prepareForRestart in interface CheckpointRestartInterface

Parameters:

aState -

aRestartInfo - The last entry object returned by the connector in the getCheckpointInformation method.

aRestartPoint -

Throws:

Exception

getUsnValues

public Entry getUsnValues()

Returns an Entry object containing the current USN synchronization values.

setUsnValues

public void setUsnValues(Entry aUsnEntry)
                  throws Exception

Sets the Connector’s current USN synchronization values to the values specified in the "aUsnEntry" parameter.

Throws:

Exception - If the given Entry object does not contain the neccessary USN values.

getVersion

public String getVersion()

Return version information

Specified by:

getVersion in interface VersionInfoInterface

Overrides:

getVersion in class LDAPConnector

Returns:

The version value