public class MConfigurationUtilities
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
M_RV_SSL_DAEMON_CERT |
static java.lang.String |
M_SSL_CIPHER_SUITES |
static java.lang.String |
M_SSL_DEBUG_TRACE |
static java.lang.String |
M_SSL_ENABLE_VERIFY_HOST |
static java.lang.String |
M_SSL_EXPECTED_HOST_NAME |
static java.lang.String |
M_SSL_IDENTITY_CERT |
static java.lang.String |
M_SSL_IDENTITY_CERT_PLUS_KEY |
static java.lang.String |
M_SSL_IDENTITY_OBJECT_TYPE |
static java.lang.String |
M_SSL_IDENTITY_PASSPHRASE |
static java.lang.String |
M_SSL_IDENTITY_PASSWORD |
static java.lang.String |
M_SSL_IDENTITY_USER_NAME |
static java.lang.String |
M_SSL_ISSUER_CERT |
static java.lang.String |
M_SSL_ISSUER_PRIVATE_KEY |
static java.lang.String |
M_SSL_TRACE |
static java.lang.String |
M_SSL_TRUSTED_URL |
Constructor and Description |
---|
MConfigurationUtilities(MApp app)
This class should be instantiated after
MApp.start() is called. |
MConfigurationUtilities(MApp app,
MProperties defaultProperties)
This class should be instantiated after
MApp.start() is called. |
Modifier and Type | Method and Description |
---|---|
void |
addAdvisorySubject(java.lang.String subject) |
void |
addAdvisorySubjectSession(java.lang.String subject,
java.lang.String session) |
void |
addComponentStartupState(java.lang.String compName,
java.lang.String state) |
java.lang.Object |
addHawkMethod(MComponent microAgent,
java.lang.String name,
java.lang.String help,
java.lang.String index,
java.lang.String type)
Deprecated.
|
void |
addHawkMethodInputParam(java.lang.Object hawkMethod,
java.lang.String name,
java.lang.String help,
java.lang.String type,
java.lang.String valueChoices,
java.lang.String legalValueChoices)
Deprecated.
|
void |
addHawkMethodOutputParam(java.lang.Object hawkMethod,
java.lang.String name,
java.lang.String help,
java.lang.String type)
Deprecated.
|
void |
addRvCmPublisherPreRegister(MComponent rvCmPublisher,
java.lang.String listener) |
void |
addTraceMapping(java.lang.String role,
MComponent sink) |
MComponent |
createFileSink(java.lang.String name,
java.lang.String fileName,
int fileLimit,
int fileCount,
boolean appendMode) |
MComponent |
createFileSink(java.lang.String name,
java.lang.String fileName,
int fileLimit,
int fileCount,
int timeInterval,
java.lang.String fileEncoding,
boolean appendMode) |
MComponent |
createHawkMicroAgent(java.lang.String microAgentName,
java.lang.String help,
java.lang.String session)
Deprecated.
|
MComponent |
createHawkSink(java.lang.String name,
java.lang.String microAgentName) |
MComponent |
createMatchingEndpoint(java.lang.String url,
MProperties objectProperties,
java.lang.String sessionName)
Create a matching endpoint given an endpoint URL.
|
MComponent |
createMatchingEndpoint(java.lang.String url,
java.lang.String sessionName)
Create a matching endpoint given an endpoint URL.
|
MComponent |
createPlugin(java.lang.String pluginName,
java.lang.String classRefStr,
MProperties properties) |
MComponent |
createPublisher(java.lang.String p_name,
java.lang.String p_session,
int p_protocol,
java.lang.String p_subject,
boolean p_assignMsgGUID) |
MComponent |
createRpcClient(java.lang.String clientName,
MEndpointSpec endpointSpec,
java.lang.String className) |
MComponent |
createRpcClient(java.lang.String p_name,
java.lang.String p_sessionName,
int p_protocol,
java.lang.String p_subjectName,
int p_timeout,
java.lang.String p_classRef) |
MComponent |
createRpcServer(java.lang.String serverName,
MEndpointSpec endpointSpec,
java.lang.String className) |
MComponent |
createRpcServer(java.lang.String p_name,
java.lang.String p_sessionName,
int p_protocol,
java.lang.String p_subjectName,
java.lang.String p_classRef) |
MComponent |
createRvaSession(java.lang.String name,
java.lang.String host,
int port) |
MComponent |
createRvCmPublisher(java.lang.String name,
java.lang.String session,
java.lang.String subject,
java.lang.String replySubject,
int messageTimeout,
java.lang.String wireformat) |
MComponent |
createRvCmqRpcServer(java.lang.String name,
java.lang.String session,
java.lang.String subject,
java.lang.String classRef) |
MComponent |
createRvCmqSession(java.lang.String name,
java.lang.String service,
java.lang.String network,
java.lang.String daemon,
java.lang.String cmqName,
int workerWeight,
int workerTasks,
int schedulerWeight,
int schedulerHeartbeat,
int schedulerActivation) |
MComponent |
createRvCmqSubscriber(java.lang.String name,
java.lang.String session,
java.lang.String subject,
int listenTimeout,
java.lang.String wireformat) |
MComponent |
createRvCmRpcClient(java.lang.String name,
java.lang.String session,
java.lang.String subject,
java.lang.String classRef,
int invocationTimeout) |
MComponent |
createRvCmRpcServer(java.lang.String name,
java.lang.String session,
java.lang.String subject,
java.lang.String classRef) |
MComponent |
createRvCmSession(java.lang.String name,
java.lang.String service,
java.lang.String network,
java.lang.String daemon,
java.lang.String cmName,
java.lang.String ledgerFile,
boolean requireOldMessages,
int defaultTimeLimit,
java.lang.String relayAgent,
boolean syncLedger,
long l_syncLedgerTime) |
MComponent |
createRvCmSubscriber(java.lang.String name,
java.lang.String session,
java.lang.String subject,
int listenTimeout,
java.lang.String wireformat) |
MComponent |
createRvPublisher(java.lang.String name,
java.lang.String session,
java.lang.String subject,
java.lang.String replySubject,
java.lang.String wireformat) |
MComponent |
createRvRpcClient(java.lang.String name,
java.lang.String session,
java.lang.String subject,
int invocationTimeout,
java.lang.String classRef) |
MComponent |
createRvRpcServer(java.lang.String name,
java.lang.String session,
java.lang.String subject,
java.lang.String classRef) |
MComponent |
createRvSession(java.lang.String name,
java.lang.String service,
java.lang.String network,
java.lang.String daemon) |
MComponent |
createRvSubscriber(java.lang.String name,
java.lang.String session,
java.lang.String subject,
int listenTimeout,
java.lang.String wireformat) |
MComponent |
createSink(java.lang.String name,
java.lang.String sessionName,
java.lang.String subject) |
MStartup |
createStartup(boolean showBanner,
boolean hasStdMicroAgent,
java.lang.String stdMicroAgentName,
boolean hasClassMicroAgent,
java.lang.String classMicroAgentName,
java.lang.String defaultStartupState,
java.lang.String defaultSessionName,
java.lang.String defaultMicroAgentSessionName,
int hawkStdMethodTimeout,
int hawkClassMethodTimeout) |
MComponent |
createStderrSink(java.lang.String name) |
MComponent |
createStdoutSink(java.lang.String name) |
MComponent |
createSubscriber(java.lang.String p_name,
java.lang.String p_sessionName,
int p_protocol,
java.lang.String p_subjectName,
int p_timeout) |
MComponent |
createTimer(java.lang.String name,
int interval,
boolean repeating) |
MApp |
getApp() |
protected byte[] |
getOptionalBytes(MProperties p_properties,
java.lang.String attrName,
byte[] defaultValue) |
void |
loadComponents(java.lang.String url)
Given a url, load all components under it.
|
void |
loadComponents(java.lang.String url,
MProperties properties)
Given a url, load all components under it.
|
void |
loadConfigObjects(java.lang.String path)
Given a url, load all components and metadata.
|
void |
loadConfigObjects(java.lang.String path,
MProperties properties)
Load all components located at the specified url.
|
void |
loadMetadata(java.lang.String p_path) |
void |
loadMetadata(java.lang.String p_path,
MProperties p_properties) |
void |
loadTransformationPlugin(java.lang.String p_path)
Deprecated.
|
void |
loadTransformationPlugin(java.lang.String p_path,
MProperties p_properties)
Deprecated.
|
void |
setDefaultProperties(MProperties defaultProperties)
Set a default
MProperties for use by MConfigurationUtilities . |
public static final java.lang.String M_SSL_IDENTITY_OBJECT_TYPE
public static final java.lang.String M_SSL_IDENTITY_USER_NAME
public static final java.lang.String M_SSL_IDENTITY_PASSWORD
public static final java.lang.String M_SSL_IDENTITY_CERT
public static final java.lang.String M_SSL_IDENTITY_PASSPHRASE
public static final java.lang.String M_SSL_TRUSTED_URL
public static final java.lang.String M_SSL_ISSUER_CERT
public static final java.lang.String M_SSL_ISSUER_PRIVATE_KEY
public static final java.lang.String M_SSL_IDENTITY_CERT_PLUS_KEY
public static final java.lang.String M_SSL_TRACE
public static final java.lang.String M_SSL_DEBUG_TRACE
public static final java.lang.String M_SSL_ENABLE_VERIFY_HOST
public static final java.lang.String M_SSL_EXPECTED_HOST_NAME
public static final java.lang.String M_SSL_CIPHER_SUITES
public static final java.lang.String M_RV_SSL_DAEMON_CERT
public MConfigurationUtilities(MApp app)
MApp.start()
is called. This
can be created in MApp.onInitialization()
.app
- Adapter application associated with this MConfigurationUtilities
object.MConfigurationUtilities( MApp app, MProperties defaultProperties)
public MConfigurationUtilities(MApp app, MProperties defaultProperties)
MApp.start()
is called. This
can be created in MApp.onInitialization()
.app
- Adapter application associated with this MConfigurationUtilities
object.defaultProperties
- The default MProperties
instance for configuration information.MConfigurationUtilities(MApp app)
public void setDefaultProperties(MProperties defaultProperties)
MProperties
for use by MConfigurationUtilities
.
The MConfigurationUtilities
normally uses the properties specified by
defaultProperties
to create components by default. To use a different
MProperties
, use methods that take in a MProperties
as a parameter.
defaultProperties
- The MProperties
instance to be used by default
in subsequent MConfigurationUtilities
method calls.public MComponent createRvaSession(java.lang.String name, java.lang.String host, int port) throws MException
MException
public MComponent createRvSession(java.lang.String name, java.lang.String service, java.lang.String network, java.lang.String daemon) throws MException
MException
public MComponent createRvCmSession(java.lang.String name, java.lang.String service, java.lang.String network, java.lang.String daemon, java.lang.String cmName, java.lang.String ledgerFile, boolean requireOldMessages, int defaultTimeLimit, java.lang.String relayAgent, boolean syncLedger, long l_syncLedgerTime) throws MException
MException
public MComponent createRvCmqSession(java.lang.String name, java.lang.String service, java.lang.String network, java.lang.String daemon, java.lang.String cmqName, int workerWeight, int workerTasks, int schedulerWeight, int schedulerHeartbeat, int schedulerActivation) throws MException
MException
public MComponent createPublisher(java.lang.String p_name, java.lang.String p_session, int p_protocol, java.lang.String p_subject, boolean p_assignMsgGUID) throws MException
MException
public MComponent createSubscriber(java.lang.String p_name, java.lang.String p_sessionName, int p_protocol, java.lang.String p_subjectName, int p_timeout) throws MException
MException
public MComponent createTimer(java.lang.String name, int interval, boolean repeating) throws MException
MException
public MComponent createRpcClient(java.lang.String clientName, MEndpointSpec endpointSpec, java.lang.String className) throws MException
MException
public MComponent createRpcClient(java.lang.String p_name, java.lang.String p_sessionName, int p_protocol, java.lang.String p_subjectName, int p_timeout, java.lang.String p_classRef) throws MException
MException
public MComponent createRpcServer(java.lang.String serverName, MEndpointSpec endpointSpec, java.lang.String className) throws MException
MException
public MComponent createRpcServer(java.lang.String p_name, java.lang.String p_sessionName, int p_protocol, java.lang.String p_subjectName, java.lang.String p_classRef) throws MException
MException
public MComponent createFileSink(java.lang.String name, java.lang.String fileName, int fileLimit, int fileCount, boolean appendMode) throws MException
MException
public MComponent createFileSink(java.lang.String name, java.lang.String fileName, int fileLimit, int fileCount, int timeInterval, java.lang.String fileEncoding, boolean appendMode) throws MException
MException
public MComponent createSink(java.lang.String name, java.lang.String sessionName, java.lang.String subject) throws MException
MException
public MComponent createHawkSink(java.lang.String name, java.lang.String microAgentName) throws MException
MException
public MComponent createStderrSink(java.lang.String name) throws MException
MException
public MComponent createStdoutSink(java.lang.String name) throws MException
MException
public MComponent createHawkMicroAgent(java.lang.String microAgentName, java.lang.String help, java.lang.String session) throws MException
MException
public MComponent createMatchingEndpoint(java.lang.String url, java.lang.String sessionName) throws MException
Given an endpoint URL (for example, a TIBCO Rendezvous publisher URL), a matching
endpoint TIBCO Rendezvous subscriber is created. The name of the new TIBCO Rendezvous
subscriber created is composed of the TIBCO Rendezvous publisher name with "_sdk
" appended to it.
For a TIBCO Rendezvous CMQ subscriber the matching endpoint created is a TIBCO Rendezvous CM publisher. Similarly, a matching TIBCO Rendezvous CM client is created of a TIBCO Rendezvous CMQ server.
The endpoint is loaded into the MComponentRegistry
.
This method uses the default MProperties
to create a matching endpoint.
url
- URL of the endpoint to be created.sessionName
- The name of the session in which to create this endpoint.MException
public MComponent createMatchingEndpoint(java.lang.String url, MProperties objectProperties, java.lang.String sessionName) throws MException
Given an endpoint URL (for example, a TIBCO Rendezvous publisher URL), a matching
endpoint TIBCO Rendezvous subscriber is created. The name of the new TIBCO Rendezvous
subscriber created is composed of the TIBCO Rendezvous publisher name with "_sdk
" appended to it.
For a TIBCO Rendezvous CMQ subscriber the matching endpoint created is a TIBCO Rendezvous CM publisher. Similarly, a matching TIBCO Rendezvous CM client is created of a TIBCO Rendezvous CMQ server.
The endpoint is loaded into the MComponentRegistry
.
This method uses the specified MProperties
to create a matching endpoint.
url
- URL of the endpoint to be created.objectProperties
- The properties in which this url is found.sessionName
- The name of the session in which to create this endpoint.MException
public void loadComponents(java.lang.String url) throws MException
This method uses the default MProperties
to load components.
The components are loaded into the MComponentRegistry
.
url
- Location of components.MException
public void loadComponents(java.lang.String url, MProperties properties) throws MException
This method uses the specified MProperties
to load components.
The components are loaded into the MComponentRegistry
.
url
- Location of components.properties
- The MProperties
used to load components.MException
public void loadConfigObjects(java.lang.String path) throws MException
This method uses the specified MProperties
to load components and metadata.
The components are loaded into the MComponentRegistry
.
MClassRegistry
.path
- Location of repository object.MException
public void loadConfigObjects(java.lang.String path, MProperties properties) throws MException
MProperties
to load components and metadata.
The components are loaded into the MComponentRegistry
.
The metadata are loaded into the MClassRegistry.path
- Location of components.properties
- The MProperties
used to load components.MException
public void loadMetadata(java.lang.String p_path) throws MException
MException
public void loadMetadata(java.lang.String p_path, MProperties p_properties) throws MException
MException
public void loadTransformationPlugin(java.lang.String p_path) throws MException
MException
public void loadTransformationPlugin(java.lang.String p_path, MProperties p_properties) throws MException
MException
public void addTraceMapping(java.lang.String role, MComponent sink) throws MException
MException
public java.lang.Object addHawkMethod(MComponent microAgent, java.lang.String name, java.lang.String help, java.lang.String index, java.lang.String type) throws MException
MException
public void addHawkMethodInputParam(java.lang.Object hawkMethod, java.lang.String name, java.lang.String help, java.lang.String type, java.lang.String valueChoices, java.lang.String legalValueChoices) throws MException
MException
public void addHawkMethodOutputParam(java.lang.Object hawkMethod, java.lang.String name, java.lang.String help, java.lang.String type) throws MException
MException
public MComponent createRvPublisher(java.lang.String name, java.lang.String session, java.lang.String subject, java.lang.String replySubject, java.lang.String wireformat) throws MException
MException
public MComponent createRvCmPublisher(java.lang.String name, java.lang.String session, java.lang.String subject, java.lang.String replySubject, int messageTimeout, java.lang.String wireformat) throws MException
MException
public void addRvCmPublisherPreRegister(MComponent rvCmPublisher, java.lang.String listener) throws MException
MException
public MComponent createRvSubscriber(java.lang.String name, java.lang.String session, java.lang.String subject, int listenTimeout, java.lang.String wireformat) throws MException
MException
public MComponent createRvCmSubscriber(java.lang.String name, java.lang.String session, java.lang.String subject, int listenTimeout, java.lang.String wireformat) throws MException
MException
public MComponent createRvCmqSubscriber(java.lang.String name, java.lang.String session, java.lang.String subject, int listenTimeout, java.lang.String wireformat) throws MException
MException
public MComponent createRvRpcClient(java.lang.String name, java.lang.String session, java.lang.String subject, int invocationTimeout, java.lang.String classRef) throws MException
MException
public MComponent createRvCmRpcClient(java.lang.String name, java.lang.String session, java.lang.String subject, java.lang.String classRef, int invocationTimeout) throws MException
MException
public MComponent createRvRpcServer(java.lang.String name, java.lang.String session, java.lang.String subject, java.lang.String classRef) throws MException
MException
public MComponent createRvCmRpcServer(java.lang.String name, java.lang.String session, java.lang.String subject, java.lang.String classRef) throws MException
MException
public MComponent createRvCmqRpcServer(java.lang.String name, java.lang.String session, java.lang.String subject, java.lang.String classRef) throws MException
MException
public MStartup createStartup(boolean showBanner, boolean hasStdMicroAgent, java.lang.String stdMicroAgentName, boolean hasClassMicroAgent, java.lang.String classMicroAgentName, java.lang.String defaultStartupState, java.lang.String defaultSessionName, java.lang.String defaultMicroAgentSessionName, int hawkStdMethodTimeout, int hawkClassMethodTimeout) throws MException
MException
public void addComponentStartupState(java.lang.String compName, java.lang.String state) throws MException
MException
public MComponent createPlugin(java.lang.String pluginName, java.lang.String classRefStr, MProperties properties) throws MException
MException
public MApp getApp()
public void addAdvisorySubject(java.lang.String subject) throws MException
MException
public void addAdvisorySubjectSession(java.lang.String subject, java.lang.String session) throws MException
MException
protected byte[] getOptionalBytes(MProperties p_properties, java.lang.String attrName, byte[] defaultValue)