com.ibm.di.api.local.impl
Class SessionImpl

java.lang.Object
  com.ibm.di.api.local.impl.SessionImpl

All Implemented Interfaces:

Session

public class SessionImpl
extends Object
implements Session

Constructor Summary

SessionImpl()

SessionImpl(String aUserId)

Method Summary

void	addEventListener(DIEventListener aListener, String aTypeFilter, String aIdFilter) Registers an Event Listener with the Session.
void	checkInAndLeaveCheckedOut(MetamergeConfig aConfiguration, String aRelativePath) Checks in the specified configuration and leaves it checked out.
void	checkInConfiguration(MetamergeConfig aConfiguration, String aRelativePath) Saves the specified configuration and releases the lock.
void	checkInConfiguration(MetamergeConfig aConfiguration, String aRelativePath, boolean aEncrypt) Encrypts and saves the specified configuration and releases the lock.
MetamergeConfig	checkOutConfiguration(String aRelativePath) Checks out the specified configuration.
MetamergeConfig	checkOutConfiguration(String aRelativePath, String aPassword) Checks out the specified password protected configuration.
ConfigInstance	checkOutConfigurationAndLoad(String aRelativePath) Checks out the specified configuration and starts a temporary Config Instance on the Server.
ConfigInstance	checkOutConfigurationAndLoad(String aRelativePath, String aPassword) Checks out the specified configuration and starts a temporary Config Instance on the Server.
ConfigInstance	createNewConfigInstance(String aConfigUrl)
ConfigInstance	createNewConfigInstance(String aConfigUrl, String aPassword)
MetamergeConfig	createNewConfiguration(String aRelativePath, boolean aOverwrite) Creates a new empty configuration and immediately checks it out.
ConfigInstance	createNewConfigurationAndLoad(String aRelativePath, boolean aOverwrite) Creates a new empty configuration, immediately checks it out and loads a temporary Config Instance on the Server.
AssemblyLine[]	getAssemblyLines() Returns started AssemblyLines corresponding to the currently started configurations.
String	getConfigFolderPath() Gets the value of the api.config.folder property as a complete path.
ConfigInstance	getConfigInstance(String aConfigId) Returns configuration instance corresponding to a specific configuration ID.
ConfigInstance[]	getConfigInstances() Returns all currently started configuration instances.
EventHandler[]	getEventHandlers() Returns started EventHandlers corresponding to the currently started configurations.
Identity	getIdentity()
SecurityRegistry	getSecurityRegistry() Returns information about the restrictions the current user has.
ServerInfo	getServerInfo() Retrieves the Server information.
SystemLog	getSystemLog() Returns information about the System logging.
SystemQueue	getSystemQueue() Gets the SystemQueue Server API object
TombstoneManager	getTombstoneManager() Returns the TombstoneManager object.
Object	invokeCustom(String aCustomClassName, String aMethodName, Object[] aParams) Invokes the specified method from the specified class.
Object	invokeCustom(String aCustomClassName, String aMethodName, Object[] aParamsValue, String[] aParamsClass) Invokes the specified method from the specified class.
boolean	isConfigurationCheckedOut(String aRelativePath) Checks if the specified configuration is checked out on the Server.
boolean	isSSLon() Checks if current session is over SSL.
ArrayList	listAllConfigurations() Returns a list all configurations in the directory subtree of the Server configuration codebase folder.
ArrayList	listConfigurations(String aRelativePath) Returns a list of all configurations in the specified folder.
ArrayList	listFolders(String aRelativePath) Returns a list of the child folders of the specified folder.
boolean	releaseConfigurationLock(String aRelativePath) Administratively releases the lock of the specified configuration.
boolean	removeEventListener(DIEventListener aListener) Unregisters an Event Listener with the Session.
void	sendCustomNotification(String aType, String aId, Object aData) Sends a custom, user defined notification to all registered listeners.
void	sendEventToACT(Serializable event) Processes an event by the Active Correlation Technology engine of the TDI server.
void	shutDownServer() Shuts down the ITDI server.
void	shutDownServer(int aExitCode) Shuts down the TDI Server with the specified exit code.
ConfigInstance	startConfigInstance(String configToken) Starts a new Config Instance on the Server with the configuration given.
ConfigInstance	startConfigInstance(String configToken, boolean aKeepAlive, String aPassword) Starts a new Config Instance on the Server with the configuration given.
boolean	undoCheckOut(String aRelativePath) Releases the lock on the specified configuration, thus aborting all changes being done.

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionImpl

public SessionImpl()

SessionImpl

public SessionImpl(String aUserId)
            throws DIException

Throws:

DIException

Method Detail

getServerInfo

public ServerInfo getServerInfo()
                         throws DIException

Description copied from interface: Session

Retrieves the Server information.

Specified by:

getServerInfo in interface Session

Returns:

ServerInfo object representing the information gathered from the Server.

Throws:

DIException - if an error occurs while retrieving the Server information.

getConfigInstances

public ConfigInstance[] getConfigInstances()
                                    throws DIException

Description copied from interface: Session

Returns all currently started configuration instances.

Specified by:

getConfigInstances in interface Session

Returns:

ConfigInstance array each value representing currently started configuration instance.

Throws:

DIException - if an error occurs while retrieving the information about the currently started configuration instances.

getConfigInstance

public ConfigInstance getConfigInstance(String aConfigId)
                                 throws DIException

Description copied from interface: Session

Returns configuration instance corresponding to a specific configuration ID.

Specified by:

getConfigInstance in interface Session

Parameters:

aConfigId - the ID of the wanted configuration.

Returns:

ConfigInstance object corresponding to the specified configuration ID or null if the configuration ID is not found in the list of currently started configurations.

Throws:

DIException - if an error occurs while retrieving the information.

getAssemblyLines

public AssemblyLine[] getAssemblyLines()
                                throws DIException

Description copied from interface: Session

Returns started AssemblyLines corresponding to the currently started configurations.

Specified by:

getAssemblyLines in interface Session

Returns:

AssemblyLine array each value corresponding to a started AssemblyLine.

Throws:

DIException - if an error occurs while retrieving the information about the AssemblyLines.

getEventHandlers

public EventHandler[] getEventHandlers()
                                throws DIException

Description copied from interface: Session

Returns started EventHandlers corresponding to the currently started configurations.

Specified by:

getEventHandlers in interface Session

Returns:

EventHandler array each value corresponding to a started EventHandler.

Throws:

DIException - if an error occurs while retrieving the information about the EventHandlers.

startConfigInstance

public ConfigInstance startConfigInstance(String configToken)
                                   throws DIException

Description copied from interface: Session

Starts a new Config Instance on the Server with the configuration given.

Specified by:

startConfigInstance in interface Session

Parameters:

configToken - The URL where the configuration file is loaded from or the Solution Name of the configuration file. Only configuration files located in the configuration codebase folder can be referenced by Solution Name.

Returns:

ConfigInstance object representing currently started configuration instance.

Throws:

DIException - if an error occurs on starting the new Config Instance.

startConfigInstance

public ConfigInstance startConfigInstance(String configToken,
                                          boolean aKeepAlive,
                                          String aPassword)
                                   throws DIException

Description copied from interface: Session

Starts a new Config Instance on the Server with the configuration given.

Specified by:

startConfigInstance in interface Session

Parameters:

configToken - The URL where the configuration file is loaded from or the Solution Name of the configuration file. Only configuration files located in the configuration codebase folder can be referenced by Solution Name.

aKeepAlive - When true the Config Instance will stay alive even when no threads are running, when false the Config Instance will automatically terminate when its last thread terminates.

aPassword - Specify the pasword of the conofiguration when it is password-protected; specify null when the configuration is not password-protected.

Returns:

ConfigInstance object representing currently started configuration instance.

Throws:

DIException - if an error occurs on starting the new Config Instance.

createNewConfigInstance

public ConfigInstance createNewConfigInstance(String aConfigUrl)
                                       throws DIException

Specified by:

createNewConfigInstance in interface Session

Parameters:

aConfigUrl - The URL of the new configuration file to be created.

Throws:

DIException - if an error occurs while creating the new Config Instance.

createNewConfigInstance

public ConfigInstance createNewConfigInstance(String aConfigUrl,
                                              String aPassword)
                                       throws DIException

Specified by:

createNewConfigInstance in interface Session

Parameters:

aConfigUrl - The URL of the new configuration file to be created.

aPassword - If this parameter is not null, the new configuration will be protected with the given password.

Throws:

DIException - if an error occurs while creating the new Config Instance.

shutDownServer

public void shutDownServer()
                    throws DIException

Description copied from interface: Session

Shuts down the ITDI server.

Specified by:

shutDownServer in interface Session

Throws:

DIException - if an error occurs while shutting down the server.

shutDownServer

public void shutDownServer(int aExitCode)
                    throws DIException

Description copied from interface: Session

Shuts down the TDI Server with the specified exit code.

Specified by:

shutDownServer in interface Session

Parameters:

aExitCode - the exit code used to shut down TDI Server.

Throws:

DIException - if an error occurs while shutting down the server.

getSecurityRegistry

public SecurityRegistry getSecurityRegistry()
                                     throws DIException

Description copied from interface: Session

Returns information about the restrictions the current user has.

Specified by:

getSecurityRegistry in interface Session

Returns:

SecurityRegistry object which represents the restrictions to the current user.

Throws:

DIException - if an error occurs while retrieving security information.

getSystemLog

public SystemLog getSystemLog()
                       throws DIException

Description copied from interface: Session

Returns information about the System logging.

Specified by:

getSystemLog in interface Session

Returns:

SystemLog object containing log information.

Throws:

DIException - if an error occurs while retrieving the System logging information.

addEventListener

public void addEventListener(DIEventListener aListener,
                             String aTypeFilter,
                             String aIdFilter)
                      throws DIException

Description copied from interface: Session

Registers an Event Listener with the Session.

Specified by:

addEventListener in interface Session

Parameters:

aListener - The Event Listener to register with the Session.

aTypeFilter - A filter for the type of events.

aIdFilter - A filter for the id of events.

Throws:

DIException - if an error occurs while registering the listener.

removeEventListener

public boolean removeEventListener(DIEventListener aListener)
                            throws DIException

Description copied from interface: Session

Unregisters an Event Listener with the Session.

Specified by:

removeEventListener in interface Session

Parameters:

aListener - The Event Listener to unregister.

Returns:

true if the EventListener is successfully unregistered, false otherwise.

Throws:

DIException - if an error occurs while unregistering the listener.

getTombstoneManager

public TombstoneManager getTombstoneManager()
                                     throws DIException

Description copied from interface: Session

Returns the TombstoneManager object. Tombstones can be queried and cleared through this object.

Specified by:

getTombstoneManager in interface Session

Returns:

The TombstoneManager object or null if TombstoneManeger is switched off.

Throws:

DIException - If an error occurs while getting the TombstoneManager.

isSSLon

public boolean isSSLon()
                throws DIException

Description copied from interface: Session

Checks if current session is over SSL.

Specified by:

isSSLon in interface Session

Returns:

true if current session is over SSL.

Throws:

DIException - if an error occurs while retrieving the information.

getIdentity

public Identity getIdentity()
                     throws DIException

Throws:

DIException

releaseConfigurationLock

public boolean releaseConfigurationLock(String aRelativePath)
                                 throws DIException

Description copied from interface: Session

Administratively releases the lock of the specified configuration. This call can be only executed by users with the admin role.

Specified by:

releaseConfigurationLock in interface Session

Parameters:

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

Returns:

true if the configuration lock has been release, false otherwise.

Throws:

DIException - If an error occurs during releasing the lock.

undoCheckOut

public boolean undoCheckOut(String aRelativePath)
                     throws DIException

Description copied from interface: Session

Releases the lock on the specified configuration, thus aborting all changes being done. This call can only be executed from a user that has previously checked out the configuration and only if the configuration lock has not timed out.

Specified by:

undoCheckOut in interface Session

Parameters:

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

Returns:

true if the undo operation is successful, false otherwise.

Throws:

DIException - If an error occurs during releasing the lock.

listConfigurations

public ArrayList listConfigurations(String aRelativePath)
                             throws DIException

Description copied from interface: Session

Returns a list of all configurations in the specified folder. If a configuration has a Solution Name, this name appears in the list, otherwise in the list appears the file path of the configuration. The configurations file paths returned are relative to the Server configuration codebase folder. The returned list is based on information, gathered by the Server on startup. If a new configuration file is added in the configuration codebase folder when the Server is already running, that configuration will not be listed by the method.

Specified by:

listConfigurations in interface Session

Parameters:

aRelativePath - A folder relative to the Server configuration codebase folder.

Returns:

A list of all configurations in the specified folder.

Throws:

DIException - If an error occurs while retrieving configurations.

listFolders

public ArrayList listFolders(String aRelativePath)
                      throws DIException

Description copied from interface: Session

Returns a list of the child folders of the specified folder.

Specified by:

listFolders in interface Session

Parameters:

aRelativePath - A folder relative to the Server configuration codebase folder.

Returns:

A list of the child folders of the specified folder.

Throws:

DIException - If an error occurs while retrieving child folder.

listAllConfigurations

public ArrayList listAllConfigurations()
                                throws DIException

Description copied from interface: Session

Returns a list all configurations in the directory subtree of the Server configuration codebase folder. If a configuration has a Solution Name, this name appears in the list, otherwise in the list appears the file path of the configuration. The configurations file paths returned are relative to the TDI Server configuration codebase folder. The returned list is based on information, gathered by the Server on startup. If a new configuration file is added in the configuration codebase folder when the Server is already running, that configuration will not be listed by the method.

Specified by:

listAllConfigurations in interface Session

Returns:

A list of all configurations from the whole configuration codebase directory subtree.

Throws:

DIException - If an error occurs while retrieving configurations.

checkOutConfiguration

public MetamergeConfig checkOutConfiguration(String aRelativePath)
                                      throws DIException

Description copied from interface: Session

Checks out the specified configuration. Returns the MetamergeConfig object representing the configuration and locks that configuration on the Server.

Specified by:

checkOutConfiguration in interface Session

Parameters:

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

Returns:

The MetamergeConfig object representing the specified configuration.

Throws:

DIException - If an error occurs while checking out the configuration.

checkOutConfiguration

public MetamergeConfig checkOutConfiguration(String aRelativePath,
                                             String aPassword)
                                      throws DIException

Description copied from interface: Session

Checks out the specified password protected configuration. Returns the MetamergeConfig object representing the configuration and locks that configuration on the Server.

Specified by:

checkOutConfiguration in interface Session

Parameters:

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

aPassword - Specify the password for password protected configurations.

Returns:

The MetamergeConfig object representing the specified configuration.

Throws:

DIException - If an error occurs while checking out the configuration.

checkOutConfigurationAndLoad

public ConfigInstance checkOutConfigurationAndLoad(String aRelativePath)
                                            throws DIException

Description copied from interface: Session

Checks out the specified configuration and starts a temporary Config Instance on the Server.

Specified by:

checkOutConfigurationAndLoad in interface Session

Parameters:

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

Returns:

The ConfigInstance object representing the temporary ConfigIsntance started on the Server.

Throws:

DIException - If an error occurs while checking out the configuration.

checkOutConfigurationAndLoad

public ConfigInstance checkOutConfigurationAndLoad(String aRelativePath,
                                                   String aPassword)
                                            throws DIException

Description copied from interface: Session

Checks out the specified configuration and starts a temporary Config Instance on the Server.

Specified by:

checkOutConfigurationAndLoad in interface Session

Parameters:

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

aPassword - Specify the password for password protected configurations.

Returns:

The ConfigInstance object representing the temporary ConfigIsntance started on the Server.

Throws:

DIException - If an error occurs while checking out the configuration.

checkInConfiguration

public void checkInConfiguration(MetamergeConfig aConfiguration,
                                 String aRelativePath)
                          throws DIException

Description copied from interface: Session

Saves the specified configuration and releases the lock. If a temporary ConfigInstance has been started on check out, it will be stopped as well.

Specified by:

checkInConfiguration in interface Session

Parameters:

aConfiguration - The MetamergeConfig object representing the configuration to be checked in.

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

Throws:

DIException - If an error occurs while checking in the configuration.

checkInConfiguration

public void checkInConfiguration(MetamergeConfig aConfiguration,
                                 String aRelativePath,
                                 boolean aEncrypt)
                          throws DIException

Description copied from interface: Session

Encrypts and saves the specified configuration and releases the lock. If a temporary Config Instance has been started on check out, it will be stopped as well.

Specified by:

checkInConfiguration in interface Session

Parameters:

aConfiguration - The MetamergeConfig object representing the configuration to be checked in.

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

aEncrypt - If set to true, the configuration will be encrypted on the Server.

Throws:

DIException - If an error occurs while checking in the configuration.

checkInAndLeaveCheckedOut

public void checkInAndLeaveCheckedOut(MetamergeConfig aConfiguration,
                                      String aRelativePath)
                               throws DIException

Description copied from interface: Session

Checks in the specified configuration and leaves it checked out. The timeout for the lock on the configuration is reset.

Specified by:

checkInAndLeaveCheckedOut in interface Session

Parameters:

aConfiguration - The MetamergeConfig object representing the configuration to be checked in.

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

Throws:

DIException - If an error occurs while checking in the configuration.

createNewConfiguration

public MetamergeConfig createNewConfiguration(String aRelativePath,
                                              boolean aOverwrite)
                                       throws DIException

Description copied from interface: Session

Creates a new empty configuration and immediately checks it out. If a configuration with the specified path already exists and the aOverwrite parameter is set to false the operation will fail and an Exception will be thrown.

Specified by:

createNewConfiguration in interface Session

Parameters:

aRelativePath - The path of the new configuration file relative to the Server configuration codebase folder.

aOverwrite - Specify whether to overwrite or not an already exising configuration file.

Returns:

The MetamergeConfig object representing the newly created configuration.

Throws:

DIException - If an error occurs while creating the new configuration.

createNewConfigurationAndLoad

public ConfigInstance createNewConfigurationAndLoad(String aRelativePath,
                                                    boolean aOverwrite)
                                             throws DIException

Description copied from interface: Session

Creates a new empty configuration, immediately checks it out and loads a temporary Config Instance on the Server. If a configuration with the specified path already exists and the aOverwrite parameter is set to false the operation will fail and an Exception will be thrown.

Specified by:

createNewConfigurationAndLoad in interface Session

Parameters:

aRelativePath - The path of the new configuration file relative to the Server configuration codebase folder.

aOverwrite - Specify whether to overwrite or not an already exising configuration file.

Returns:

The ConfigInstance object representing the temporary ConfigIsntance started on the Server.

Throws:

DIException - If an error occurs while creating the new configuration.

isConfigurationCheckedOut

public boolean isConfigurationCheckedOut(String aRelativePath)
                                  throws DIException

Description copied from interface: Session

Checks if the specified configuration is checked out on the Server.

Specified by:

isConfigurationCheckedOut in interface Session

Parameters:

aRelativePath - The path to the configuration relative to the Server configuration codebase folder or the Solution Name of the configuration (the configuration must be inside the configuration codebase folder).

Returns:

true if the specified configuration is checked out, false otherwise.

Throws:

DIException - If an error occurs while checking the configuration.

sendCustomNotification

public void sendCustomNotification(String aType,
                                   String aId,
                                   Object aData)
                            throws DIException

Description copied from interface: Session

Sends a custom, user defined notification to all registered listeners.

Specified by:

sendCustomNotification in interface Session

Parameters:

aType - Notification type, will be automatically prefixed with "user."

aId - Notification ID, usually identifies the object this event originated from.

aData - Custom user data. Make sure the object passed is serializable if you want to send this event notification in a remote context.

Throws:

DIException - If an error occurs while sending the notification.

getSystemQueue

public SystemQueue getSystemQueue()
                           throws DIException

Description copied from interface: Session

Gets the SystemQueue Server API object

Specified by:

getSystemQueue in interface Session

Returns:

the ServerAPI representation of the System Queue

Throws:

DIException - if the System Queue is turned off or the System Queue cannot be initialized

getConfigFolderPath

public String getConfigFolderPath()

Description copied from interface: Session

Gets the value of the api.config.folder property as a complete path. If not set, then returns an empty string.

Specified by:

getConfigFolderPath in interface Session

Returns:

A String containing the config folder property as a complete path.

invokeCustom

public Object invokeCustom(String aCustomClassName,
                           String aMethodName,
                           Object[] aParams)
                    throws DIException

Description copied from interface: Session

Invokes the specified method from the specified class. The method must be static. This method cannot invoke methods with null parameter values. All parameter values in the parameter object array MUST be non-null. If any value is null an Exception is thrown. If a user wants to invoke a method with a null parameter, he/she must use the other invokeCustom method. The usage of this method can be turned on/off. There is a property in the global.properties file called api.custom.method.invoke.on. If this property is set to true then this method can be invoked, otherwise an exception is thrown if this method is invoked. There is a restriction on the classes which can be directly invoked. The allowed classes are described in another property in the global.properties file called api.custom.method.invoke.allowed.classes. Only classes listed in this property can be directly invoked by this method. If a user tries to invoke a class which is not in this list then an exception is thrown.

Specified by:

invokeCustom in interface Session

Parameters:

aCustomClassName - The class containing the method to be invoked.

aMethodName - The name of the method to be invoked.

aParams - Array of parameters used by the invoked method.

Returns:

the result of dispatching the method represented with parameters aParams.

Throws:

DIException - If an error occurs while invoking the method.

invokeCustom

public Object invokeCustom(String aCustomClassName,
                           String aMethodName,
                           Object[] aParamsValue,
                           String[] aParamsClass)
                    throws DIException

Description copied from interface: Session

Invokes the specified method from the specified class. The method must be static. This method is used when the user wants to invoke the specified method with a null parameter value. The main difference between these two invokeCustom methods is that when using this method the user MUST specify the parameters' type. The usage of this method can be turned on/off. There is a property in the global.properties file called api.custom.method.invoke.on. If this property is set to true then this method can be invoked, otherwise an exception is thrown if this method is invoked. There is a restriction on the classes which can be directly invoked. The allowed classes are described in another property in the global.properties file called api.custom.method.invoke.allowed.classes. Only classes listed in this property can be directly invoked by this method. If the user tries to invoke a class which is not in this list then an exception is thrown.

Specified by:

invokeCustom in interface Session

Parameters:

aCustomClassName - The class containing the method to be invoked.

aMethodName - The name of the method to be invoked.

aParamsValue - Array of parameters used by the invoked method.

aParamsClass - The type of the parameters used by the invoked method.

Returns:

the result of dispatching the method represented with parameters' types aParamsClass.

Throws:

DIException - If an error occurs while invoking the method.

sendEventToACT

public void sendEventToACT(Serializable event)
                    throws DIException

Description copied from interface: Session

Processes an event by the Active Correlation Technology engine of the TDI server. The method returns when the engine has completely processed the event.

Specified by:

sendEventToACT in interface Session

Parameters:

event - Event to be processed by ACT engine - currently only org.eclipse.hyades.logging.events.cbe.CommonBaseEvent is supported.

Throws:

DIException - An error occurred while processing the event or the event type is not supported.