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