com.ibm.di.connector
Class JMXConnector

java.lang.Object
  com.ibm.di.connector.Connector
      com.ibm.di.connector.JMXConnector

All Implemented Interfaces:

ConnectorInterface, VersionInfoInterface

public class JMXConnector
extends Connector
implements ConnectorInterface

The JMX Connector listens for local or remote JMX notifications depending on the mode selected by setting a Connector parameter. In remote mode the Connector hooks into remote JMX systems and registers for notifications. In local mode the Connector registers for JMX notifications emitted in the TDI JVM - normally such notifications can be emitted by the JMX layer of the Server API or by other TDI components. 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

JMXConnector()
Constructor for the JMXConnector object

Method Summary

Entry	getNextEntry() Gets the next notification object
String	getVersion() Version information.
void	initialize(Object aObj) Reads connector parameter's values and initialize the Connector.
void	terminate() Terminate the connector.

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

addFindEntry, allModes, clearFindEntries, debug, debugMode, deleteEntry, 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, putEntry, 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, putEntry, queryOperations, queryReply, querySchema, reconnect, registerScriptBeans, replyEntry, selectEntries, setConfiguration, setContext, setCurrent, setLog, setMaxDuplicateEntries, setName, setParam, setRSInterface, terminateServer

Constructor Detail

JMXConnector

public JMXConnector()

Constructor for the JMXConnector object

Method Detail

initialize

public void initialize(Object aObj)
                throws 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:

Exception - If invalid Connector parameter values are supplied.

getNextEntry

public Entry getNextEntry()
                   throws Exception

Gets the next notification object

Specified by:

getNextEntry in interface ConnectorInterface

Overrides:

getNextEntry in class Connector

Returns:

The next Entry

Throws:

Exception - If retrieving the next Entry fails.

See Also:

ConnectorInterface.selectEntries()

terminate

public void terminate()
               throws 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:

Exception - If terminate fails.

getVersion

public String getVersion()

Version information.

Specified by:

getVersion in interface VersionInfoInterface

Returns:

version information