Package com.ibm.di.connector

Class ServerNotificationsConnector

java.lang.Object

com.ibm.di.connector.Connector

com.ibm.di.connector.ServerNotificationsConnector

All Implemented Interfaces:

ConnectorInterface, VersionInfoInterface

public class ServerNotificationsConnector
extends Connector
implements ConnectorInterface

The Connector listens for local or remote Server API notifications depending on the mode selected by setting a Connector parameter. In remote mode the Connector hooks into remote TDI systems and registers for notifications. In local mode the Connector registers for Server API notifications emitted in the TDI JVM - the notifications can be emitted by the Server API layer. When the Connector receives a notification it stores it into an internal Connector buffer for later retrieval by the standard getNextEntry() Connector method which is called by the AssemblyLine for Connectors in Iterator mode.

Field Summary

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

ALL_MODES, myLog, PROPERTY_MESSAGE, PROPERTY_READER, PROPERTY_WRITER

Constructor Summary

Constructors

Constructor	Description
ServerNotificationsConnector()	Constructor for the ServerNotificationListenerConnector object

Method Summary

Modifier and Type	Method	Description
Entry	getNextEntry()	Gets the next notification object
java.lang.String	getVersion()	Version information.
void	initialize(java.lang.Object aObj)	Reads connector parameter's values and initialize the Connector.
void	putEntry(Entry entry)	Emits a custom Server API notification
void	terminate()	Terminate the connector.

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

addFindEntry, allModes, clearFindEntries, debug, debugMode, deleteEntry, extractExceptionInformation, findEntry, findEntry, getBoolean, getClassInstance, getConfiguration, getContext, getFindEntryCount, getFirstFindEntry, getLog, getMaxDuplicateEntries, getModes, getModes, getName, getNextClient, getNextFindEntry, getParam, getParser, getProperty, getPushbackEntry, getRawConnectorConfiguration, getRSInterface, getUI, hasConfigValue, hasParser, initParser, isDeltaSupported, isExceptionFatal, isIOException, logError, logmsg, modEntry, modEntry, pushback, queryOperations, queryReply, querySchema, queryTables, reconnect, reconnect, registerScriptBeans, replyEntry, selectEntries, setConfiguration, setContext, setCurrent, setDebugMode, 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, queryOperations, queryReply, querySchema, reconnect, registerScriptBeans, replyEntry, selectEntries, setConfiguration, setContext, setCurrent, setLog, setMaxDuplicateEntries, setName, setParam, setRSInterface, terminateServer

Constructor Detail

ServerNotificationsConnector

public ServerNotificationsConnector()

Constructor for the ServerNotificationListenerConnector object

Method Detail

initialize

public void initialize(java.lang.Object aObj)
                throws java.lang.Exception

Reads connector parameter's values and initialize the Connector.

Specified by:

initialize in interface ConnectorInterface

Overrides:

initialize in class Connector

Parameters:

aObj - Null, Socket or ConnectorMode class

Throws:

java.lang.Exception - If invalid Connector parameter values are supplied.

getNextEntry

public Entry getNextEntry()
                   throws java.lang.Exception

Gets the next notification object

Specified by:

getNextEntry in interface ConnectorInterface

Overrides:

getNextEntry in class Connector

Returns:

The next Entry

Throws:

java.lang.Exception - If retrieving the next Entry fails.

See Also:

ConnectorInterface.selectEntries()

putEntry

public void putEntry(Entry entry)
              throws java.lang.Exception

Emits a custom Server API notification

Specified by:

putEntry in interface ConnectorInterface

Overrides:

putEntry in class Connector

Parameters:

entry - The entry that holds the notification data

Throws:

java.lang.Exception - If emiting notification fails.

terminate

public void terminate()
               throws java.lang.Exception

Terminate the connector. This function closes all connection and releases all resources used by the connector. This function also calls the parser's closeParser function if a parser is active.

Specified by:

terminate in interface ConnectorInterface

Overrides:

terminate in class Connector

Throws:

java.lang.Exception - If terminate fails.

getVersion

public java.lang.String getVersion()

Version information.

Specified by:

getVersion in interface VersionInfoInterface

Returns:

the version information