|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ConfigInstanceMBean
ConfigInstance MBean interface that defines public methods exposed through JMX layer.
Method Summary | |
---|---|
String |
getALLastLogFileName(String aALName)
Returns the name of the log file created on the last run of a given AssemblyLine. |
String |
getALLog(String aALName,
String aLogFileName)
Given an AssemblyLine name, and a log file name, retrieves the log of this AssemblyLine, stored in the specified file. |
String[] |
getALLogFileNames(String aALName)
Returns the names of all available log files for a given AssemblyLine. |
String |
getALLogLastChunk(String aALName,
String aLogFileName,
Integer aKilobytes)
Retrieves the last chunk from a specified AssemblyLine's log file. |
SchemaConfig |
getAssemblyLineInputParameters(String aAssemblyLineName)
Returns the AssemblyLine’s input parameters. |
String[] |
getAssemblyLineNames()
Returns the AssemblyLines’ names. |
SchemaConfig |
getAssemblyLineOutputParameters(String aAssemblyLineName)
Returns the AssemblyLine’s output parameters. |
ObjectName[] |
getAssemblyLines()
Returns the names of currently started AssemblyLines of the configuration each represented as ObjectName generated from AssemblyLine’s name and unique code. |
String[] |
getAssemblyLinesNames()
Deprecated. Use getAssemblyLineNames() . |
String |
getConfigId()
Returns the configuration ID generated by the server. |
String |
getConfigPath()
Retrieves the config path. |
MetamergeConfig |
getConfiguration()
Returns configuration instance representing this configuration. |
PoolDefConfig |
getConnectorPoolConfig(String aConnectorPoolName)
Returns the Connector Pool configuration object. |
int |
getConnectorPoolFreeNum(String aConnectorPoolName)
Returns the number of free Connectors in the specified Connector Pool. |
String[] |
getConnectorPoolNames()
Returns the names of all Connector Pools in the Config Instance. |
int |
getConnectorPoolSize(String aConnectorPoolName)
Returns the size of the specified Connector Pool. |
ExternalPropertiesConfig |
getExternalProperties()
Deprecated. use getTDIProperties() instead |
ExternalPropertiesConfig |
getExternalProperties(String aKey)
Deprecated. use getTDIProperties() instead |
String[] |
getExternalPropertiesKeys()
Deprecated. use getTDIProperties() instead |
String |
getGlobalUniqueID()
Returns the Config Instance GUID. |
Date |
getInstanceBootTime()
Returns the Instance boot time. |
ObjectName |
getTDIProperties()
Access to the TDIProperies for the particular config. |
int |
purgeConnectorPool(String aConnectorPoolName)
Unused Connectors will be released so that the Pool is shrunk to its minimum size. |
void |
reload()
Reloads the Config Instance with its current configuration. |
void |
saveConfiguration()
Deprecated. Not supported. |
void |
saveConfiguration(Boolean aEncrypt)
Deprecated. Not supported. |
void |
saveExternalProperties()
Deprecated. Not supported. |
void |
setConfiguration(MetamergeConfig aConfiguration)
Sets given configuration to this configuration. |
void |
setExternalProperties(ExternalPropertiesConfig aExPropConfig)
Deprecated. Not supported. |
void |
setExternalProperties(String aKey,
ExternalPropertiesConfig aExPropConfig)
Deprecated. Not supported. |
ObjectName |
startAssemblyLine(String aAssemblyLineName)
Starts the specified AssemblyLine asynchronously. |
ObjectName |
startAssemblyLine(String aAssemblyLineName,
Boolean aSync)
Starts the specified AssemblyLine. |
ObjectName |
startAssemblyLine(String aAssemblyLineName,
Entry aInputData)
Starts the specified AssemblyLine with the given input data asynchronously. |
ObjectName |
startAssemblyLine(String aAssemblyLineName,
Entry aInputData,
AssemblyLineListener aListener,
Boolean aGetLogs)
Starts asynchronously the specified AssemblyLine with the given input data and results listener. |
ObjectName |
startAssemblyLine(String aAssemblyLineName,
Entry aInputData,
AssemblyLineListener aListener,
Boolean aGetLogs,
Boolean aSync)
Starts the specified AssemblyLine with the given input data and results listener. |
ObjectName |
startAssemblyLine(String aAssemblyLineName,
Entry aInputData,
AssemblyLineListener aListener,
Boolean aGetLogs,
Boolean aSync,
Boolean aGetEntryOnEachCycle)
Starts the specified AssemblyLine with the given input data and results listener. |
ObjectName |
startAssemblyLine(String aAssemblyLineName,
Entry aInputData,
Boolean aSync)
Starts the specified AssemblyLine with the given input data. |
ObjectName |
startAssemblyLine(String aAssemblyLineName,
TaskCallBlock aTcb)
Starts asynchronously the specified AssemblyLine with the given TaskCallBlock. |
ObjectName |
startAssemblyLine(String aAssemblyLineName,
TaskCallBlock aTcb,
Boolean aSync)
Starts the specified AssemblyLine with the given TaskCallBlock. |
ObjectName |
startAssemblyLineManual(String aAssemblyLineName,
Entry aInputData)
Starts the specified AssemblyLine with the given input data in manual mode. |
void |
stop()
Stops the Config Instance. |
Methods inherited from interface com.ibm.di.api.jmx.mbeans.BaseMBean |
---|
getId, getType |
Method Detail |
---|
String getConfigId() throws DIException
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL("service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName()=="com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } var on = mb.getObjectName(); var res = jmxMBeanServer.getAttribute(on,"ConfigId"); task.logmsg("Result "+ res); } Sample output: Result C__Documents and Settings_username_My Documents_TDI_rs.xml
DIException
- if an error occurs while getting the configuration ID.MetamergeConfig getConfiguration() throws DIException
DIException
- if an error occurs while getting the configuration.void setConfiguration(MetamergeConfig aConfiguration) throws DIException
aConfiguration
- The new configuration.
DIException
- if an error occurs while setting the configuration.@Deprecated void saveConfiguration() throws DIException
DIException
@Deprecated void saveConfiguration(Boolean aEncrypt) throws DIException
DIException
@Deprecated ExternalPropertiesConfig getExternalProperties() throws DIException
getTDIProperties()
instead
DIException
- if an error occurs while getting the external properties.@Deprecated ExternalPropertiesConfig getExternalProperties(String aKey) throws DIException
getTDIProperties()
instead
aKey
- The external property object name.
DIException
- if an error occurs while getting the external properties.@Deprecated String[] getExternalPropertiesKeys() throws DIException
getTDIProperties()
instead
DIException
- if an error occurs while getting the external properties
names.@Deprecated void setExternalProperties(ExternalPropertiesConfig aExPropConfig) throws DIException
DIException
@Deprecated void setExternalProperties(String aKey, ExternalPropertiesConfig aExPropConfig) throws DIException
DIException
@Deprecated void saveExternalProperties() throws DIException
DIException
String[] getAssemblyLinesNames() throws DIException
getAssemblyLineNames()
.
DIException
String[] getAssemblyLineNames() throws DIException
DIException
- if an error occurs while getting the AssemblyLines’ names.SchemaConfig getAssemblyLineInputParameters(String aAssemblyLineName) throws DIException
aAssemblyLineName
- the name of the AssemblyLine.
DIException
- if an error occurs while getting the AssemblyLine's input
parameters.SchemaConfig getAssemblyLineOutputParameters(String aAssemblyLineName) throws DIException
aAssemblyLineName
- the name of the AssemblyLine.
DIException
- if an error occurs while getting the AssemblyLine's output
parameters.ObjectName[] getAssemblyLines() throws DIException
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL("service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName()=="com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } var on = mb.getObjectName(); var res = jmxMBeanServer.getAttribute(on,"AssemblyLines"); task.logmsg("Result "+ res); } Sample output: Result ServerAPI:type=AssemblyLine,id=AssemblyLines/test.2
DIException
- if an error occurs while getting the AssemblyLines’ names.ObjectName startAssemblyLine(String aAssemblyLineName) throws DIException
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL( "service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName() == "com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } var on = mb.getObjectName(); jmxMBeanServer.invoke(on, "startAssemblyLine", new Array("csv2xml"), new Array( "java.lang.String"));
aAssemblyLineName
- The name of the AssemblyLine.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLine(String aAssemblyLineName, Boolean aSync) throws DIException
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL( "service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName() == "com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } var on = mb.getObjectName(); jmxMBeanServer.invoke(on, "startAssemblyLine", new Array("csv2xml", new Boolean("false")), new Array("java.lang.String", "java.lang.Boolean"));
aAssemblyLineName
- The name of the AssemblyLine.aSync
- when true
the AssemblyLine is started
synchronously, when false
the AssemblyLine is
started asynchronously.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLine(String aAssemblyLineName, Entry aInputData) throws DIException
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL( "service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName() == "com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } var on = mb.getObjectName(); jmxMBeanServer.invoke(on, "s", new Array("csv2xml", work), new Array( "java.lang.String", "com.ibm.di.entry.Entry"));
aAssemblyLineName
- The name of the AssemblyLine.aInputData
- Initial Work Entry to run the AssemblyLine with.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLine(String aAssemblyLineName, Entry aInputData, Boolean aSync) throws DIException
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL( "service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName() == "com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } jmxMBeanServer.invoke(on, "startAssemblyLine", new Array("csv2xml", work, new Boolean("true")), new Array("java.lang.String", "com.ibm.di.entry.Entry", "java.lang.Boolean"));
aAssemblyLineName
- The name of the AssemblyLine.aInputData
- Initial Work Entry to run the AssemblyLine with.aSync
- when true
the AssemblyLine is started
synchronously, when false
the AssemblyLine is
started asynchronously.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLine(String aAssemblyLineName, Entry aInputData, AssemblyLineListener aListener, Boolean aGetLogs) throws DIException
aAssemblyLineName
- The name of the AssemblyLine.aInputData
- Initial Work Entry to run the AssemblyLine with.aListener
- A listener for Entries produced by the AssemblyLine.aGetLogs
- when true
the AssemblyLineListener delivers log
messages, when false
log messages are not
delivered.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLine(String aAssemblyLineName, Entry aInputData, AssemblyLineListener aListener, Boolean aGetLogs, Boolean aSync) throws DIException
aAssemblyLineName
- The name of the AssemblyLine.aInputData
- Initial Work Entry to run the AssemblyLine with.aListener
- A listener for Entries produced by the AssemblyLine.aGetLogs
- when true
the AssemblyLineListener delivers log
messages, when false
log messages are not
delivered.aSync
- when true
the AssemblyLine is started
synchronously, when false
the AssemblyLine is
started asynchronously.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLine(String aAssemblyLineName, Entry aInputData, AssemblyLineListener aListener, Boolean aGetLogs, Boolean aSync, Boolean aGetEntryOnEachCycle) throws DIException
aAssemblyLineName
- The name of the AssemblyLine.aInputData
- Initial Work Entry to run the AssemblyLine with.aListener
- A listener for Entries produced by the AssemblyLine.aGetLogs
- when true
the AssemblyLineListener delivers log
messages, when false
log messages are not
delivered.aSync
- when true
the AssemblyLine is started
synchronously, when false
the AssemblyLine is
started asynchronously.aGetEntryOnEachCycle
- when true
the AssemblyLineListener delivers the
current entry on each AssemblyLine cycle, when
false
the entries are not delivered.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLineManual(String aAssemblyLineName, Entry aInputData) throws DIException
aAssemblyLineName
- The name of the AssemblyLine.aInputData
- Initial Work Entry to run the AssemblyLine with.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLine(String aAssemblyLineName, TaskCallBlock aTcb) throws DIException
aAssemblyLineName
- The name of the AssemblyLine.aTcb
- The TaskCallBlock object to start the AL with.
DIException
- if an error occurs when starting the AssemblyLine.ObjectName startAssemblyLine(String aAssemblyLineName, TaskCallBlock aTcb, Boolean aSync) throws DIException
aAssemblyLineName
- The name of the AssemblyLine.aTcb
- The TaskCallBlock object to start the AL with.aSync
- when true
the AssemblyLine is started
synchronously, when false
the AssemblyLine is
started asynchronously.
DIException
- if an error occurs when starting the AssemblyLine.void reload() throws DIException
DIException
- if an error occurs while reloading the server.void stop() throws DIException
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL( "service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName() == "com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } var on = mb.getObjectName(); jmxMBeanServer.invoke(on, "stop", null, null);
DIException
- if an error occurs while stopping.String[] getALLogFileNames(String aALName) throws DIException
aALName
- the name of the AssemblyLine.
DIException
- if an error occurs while obtaining AssemblyLine's log file
names.String getALLastLogFileName(String aALName) throws DIException
aALName
- the name of the AssemblyLine.
DIException
- if an error occurs while obtaining the log file name.String getALLog(String aALName, String aLogFileName) throws DIException
aALName
- the name of the AssemblyLine.aLogFileName
- the name of the log file; no file path should be specified -
just the file name.
DIException
- if an error occurs while obtaining AssemblyLine's log.String getALLogLastChunk(String aALName, String aLogFileName, Integer aKilobytes) throws DIException
aALName
- the name of the AssemblyLine.aLogFileName
- the name of the log file; no file path should be specified -
just the file name.aKilobytes
- specifies in kilobytes the size of the log's last chunk that
will be read.
DIException
- if an error occurs while obtaining AssemblyLine's log.Date getInstanceBootTime() throws DIException
java.util.Date
specifying the date and time the
instance was started.
DIException
- if an error occurs while retrieving instance's boot time.String getGlobalUniqueID() throws DIException
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL("service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName()=="com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } var on = mb.getObjectName(); var res = jmxMBeanServer.getAttribute(on,"GlobalUniqueID"); task.logmsg("Result "+ res); } Sample output:Result 17135304020
DIException
- if an error occurs while retrieving GlobalUniqueID.String[] getConnectorPoolNames() throws DIException
DIException
- if an error occurs while retrieving Connector Pool names.int getConnectorPoolSize(String aConnectorPoolName) throws DIException
aConnectorPoolName
- the name of the Connector Pool.
DIException
- if an error occurs while retrieving Connector Pool size.int getConnectorPoolFreeNum(String aConnectorPoolName) throws DIException
aConnectorPoolName
- the name of the Connector Pool.
DIException
- if an error occurs while retrieving Connector Pool free
Connectors.PoolDefConfig getConnectorPoolConfig(String aConnectorPoolName) throws DIException
aConnectorPoolName
- the name of the Connector Pool.
DIException
- if an error occurs while retrieving Connector Pool
configuration object.int purgeConnectorPool(String aConnectorPoolName) throws DIException
aConnectorPoolName
- the name of the Connector Pool.
DIException
- if an error occurs while shrinking the Connector Pool to its
minimum size.ObjectName getTDIProperties() throws Exception
Exception
- if an error occurs while getting TDI PropertiesString getConfigPath()
Example
//for local access to jmx layer use: var jmxMBeanServer = com.ibm.di.api.jmx.JMXAgent.getMBeanServer(); var jmxUrl = new javax.management.remote.JMXServiceURL("service:jmx:rmi://localhost/jndi/rmi://localhost:1099/jmxconnector"); var jmxConnector = javax.management.remote.JMXConnectorFactory.connect(jmxUrl); var jmxMBeanServer = jmxConnector.getMBeanServerConnection(); mBeans = jmxMBeanServer.queryMBeans(null, null).iterator(); while (mBeans.hasNext()) { var mb = mBeans.next(); if (mb.getClassName()=="com.ibm.di.api.jmx.mbeans.ConfigInstance") break; } var on = mb.getObjectName(); var res = jmxMBeanServer.getAttribute(on,"ConfigPath"); task.logmsg("Result "+ res); } Sample output:Result C:\Documents and Settings\Username\My Documents\TDI\rs.xml
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |