Package com.ibm.di.connector

Class SystemQueueConnector

java.lang.Object

com.ibm.di.connector.Connector

com.ibm.di.connector.SystemQueueConnector

All Implemented Interfaces:

ConnectorInterface, VersionInfoInterface

public class SystemQueueConnector
extends Connector

The System Queue Connector provides a way to use the functionality provided by the System Queue component in TDI AssemblyLines. The Connector uses Server API sessions remote or local, depending on the mode selected by setting a Connector parameter, to connect to the System Queue. In remote mode the Connector hooks into remote TDI systems and uses Server API and System Queue in the Java Virtual Machine of that remote system. In local mode the Connector use local Server API and System Queue in the local Java Virtual Machine.

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
SystemQueueConnector()	Constructor for the SystemQueueConnector object

Method Summary

Modifier and Type	Method	Description
Entry	getNextEntry()	Gets the next Entry object from the JMS server.
java.lang.String	getVersion()	Version information.
void	initialize(java.lang.Object aObj)	Reads connector parameter's values and initialize the Connector.
void	putEntry(Entry aEntry)	Send an entry to the JMS server.

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, terminate, terminateServer

Methods inherited from class java.lang.Object

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

Constructor Detail

SystemQueueConnector

public SystemQueueConnector()

Constructor for the SystemQueueConnector 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 Entry object from the JMS server.

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 aEntry)
              throws java.lang.Exception

Send an entry to the JMS server.

Specified by:

putEntry in interface ConnectorInterface

Overrides:

putEntry in class Connector

Parameters:

aEntry - The entry to send

Throws:

java.lang.Exception - If sending the Entry fails.

getVersion

public java.lang.String getVersion()

Version information.

Returns:

the version information