com.ibm.di.connector
Class ACTConnector

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

All Implemented Interfaces:

ConnectorInterface, VersionInfoInterface

public class ACTConnector
extends Connector
implements ConnectorInterface

A Connector used to feed events into the Active Correlation Technology (ACT) engine of TDI. Events are synchronously processed - that is when 'putEntry' call returns, the event is completely processed by the ACT engine. The Connector passes events to the ACT engine through the TDI Server API. The ACT Connector can process events either via the local TDI engine, or via the engine of some remote TDI server.

Since:

TDI 6.1.1

Field Summary

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

ALL_MODES, myLog, PROPERTY_MESSAGE, PROPERTY_READER, PROPERTY_WRITER

Constructor Summary

ACTConnector()
Create an instance of the ACT Connector.

Method Summary

String	getVersion() The version of the Connector.
void	initialize(Object obj) Reads and validates the Connector's configuration parameters.
void	putEntry(Entry entry) Process a Common Base Event by the ACT Engine.

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, getNextEntry, getNextFindEntry, getParam, getParser, getProperty, getPushbackEntry, getRawConnectorConfiguration, getRSInterface, hasConfigValue, hasParser, initParser, isDeltaSupported, isExceptionFatal, isIOException, logmsg, modEntry, modEntry, pushback, queryOperations, queryReply, querySchema, queryTables, reconnect, reconnect, registerScriptBeans, replyEntry, selectEntries, setConfiguration, setContext, setCurrent, setLog, setMaxDuplicateEntries, setModes, setModes, setName, setParam, setParser, setProperty, setRSInterface, terminate, 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, getNextEntry, 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, terminate, terminateServer

Constructor Detail

ACTConnector

public ACTConnector()

Create an instance of the ACT Connector.

Method Detail

initialize

public void initialize(Object obj)
                throws Exception

Reads and validates the Connector's configuration parameters.

Opens a session to the TDI server (local or remote - depends on the configuration). Initializes the embedded CBEGeneratorFC instance, which is used to create a CommonBaseEvent objects from Entry attributes.

Specified by:

initialize in interface ConnectorInterface

Overrides:

initialize in class Connector

Parameters:

obj - User provided parameter

Throws:

Exception - Some of the configuration parameters has invalid value. Obtaining session to the TDI server failed. If the embedded CBEGeneratorFC fails to initialize.

putEntry

public void putEntry(Entry entry)
              throws Exception

Process a Common Base Event by the ACT Engine.

Specified by:

putEntry in interface ConnectorInterface

Overrides:

putEntry in class Connector

Parameters:

entry - The entry that describes a Common Base Event.

Throws:

Exception - Error while converting the Entry attributes to a CommonBaseEvent object. Error while processing the event.

getVersion

public String getVersion()

The version of the Connector.

Specified by:

getVersion in interface VersionInfoInterface