com.ibm.di.connector
Class SystemQueueConnector

java.lang.Object
  extended by com.ibm.di.connector.Connector
      extended by 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