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

SystemQueueConnector()
Constructor for the SystemQueueConnector object

Method Summary

Entry	getNextEntry() Gets the next Entry object from the JMS server.
String	getVersion() Version information.
void	initialize(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, 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(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 Entry object from the JMS server.

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()

putEntry

public void putEntry(Entry aEntry)
              throws 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:

Exception - If sending the Entry fails.

getVersion

public String getVersion()

Version information.

Returns:

the version information