public class MessageFlowProxy extends FlowProxy
BrokerProxy b = BrokerProxy.getInstance( new IntegrationNodeConnectionParameters("localhost", 4414)); ExecutionGroupProxy e = b.getExecutionGroupByName("default"); MessageFlowProxy m = e.getMessageFlowByName("mf1");
com.ibm.broker.config.proxy.MessageFlowProxy extends
com.ibm.broker.config.proxy.AdministeredObject implements
com.ibm.broker.config.proxy.DeployedObject
|
|
Responsibilities | Represents the state of a message flow that has been deployed to an integration server. |
Internal Collaborators | None |
Change Activity: -------- ----------- ------------- ------------------------------------ Reason: Date: Originator: Comments: -------- ----------- ------------- ------------------------------------ 25103.8 2004-03-18 HDMPL v6 Release 45112.7 2007-07-30 HDMPL v6.1 Release: Methods now return genericized types where relevant Added getQueues() Added getNodeTypes() Added setAdditionalInstances(String) Added getDeployedPolicySetBindingsNames() Added getDeployedPolicySetNames() Added MessageFlowProxy.PolicySetName Added MessageFlowProxy.PolicySetBindingsName 51517 2008-06-12 HDMPL v7.0 Release: Deprecated immediate parameter on stop() Added getNodes() Added getNodeConnections() Added getNodeByName() Added setServiceTrace() Added setStatisticsEnabled() Added setStatisticsNodeDetailLevel() Added setStatisticsThreadDetailLevel() Added setStatisticsAccountingOrigin() Added resetArchiveStatistics() Added getStatisticsEnabled() Added getStatisticsNodeDetailLevel() Added getStatisticsThreadDetailLevel() Added getStatisticsOutputFormat() Added getStatisticsAccountingOrigin() Added enableBasicStatistics() 80006.2 2011-05-13 HDCAB v8.0 Release: Added getActivityLog() 80006.4 2011-09-30 HDCAB Added getStartMode(), setStartMode()
Modifier and Type | Class and Description |
---|---|
class |
MessageFlowProxy.Node
A small class that represents a node in a flow.
|
class |
MessageFlowProxy.NodeConnection
A small class that represents the connection
between two nodes in a flow.
|
class |
MessageFlowProxy.PolicySetBindingsName
This class represents a PolicySetBinding associated in some way with the message flow.
|
class |
MessageFlowProxy.PolicySetName
This class represents a PolicySet associated in some way with the message flow.
|
static class |
MessageFlowProxy.UserTrace
A small structure that represents all the possible types of
user trace.
|
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
copyright
IBM Copyright
|
protected static java.lang.String |
sccsid
Version information
|
baseRetryWaitTime, LOCAL_ATTRIBUTE_IDENTIFIER, maxRetries, objectUnavailable, owningPool, potentialNewSubcomponents, propertyUpdateLock, retryWaitTimeIncrement, subcomponentsToBeSubmittedForCreationInCurrentBatch, UUID_DELIMITER
BARNAME_KEYWORD, USAGE_KEYWORD, VERSION_KEYWORD
Modifier | Constructor and Description |
---|---|
protected |
MessageFlowProxy(com.ibm.broker.config.proxy.AdministeredObjectPool aop)
DO NOT USE THIS CONSTRUCTOR - use ExecutionGroupProxy.getMessageFlowByName()
instead.
|
protected |
MessageFlowProxy(com.ibm.broker.config.proxy.AdministeredObjectPool aop,
ConfigurationObjectType inParentType) |
Modifier and Type | Method and Description |
---|---|
void |
clearRecordedTestData()
This method clears all recorded test data for the message flow
|
void |
enableBasicStatistics()
Configures a standard set of snapshot statistics properties for the
message flow and enables the gathering of these statistics.
|
boolean |
fullNameMatches(java.lang.String fileName)
Tests if the name of this deployed object matches the
fileName passed in.
|
ActivityLogProxy |
getActivityLog()
Returns an ActivityLogProxy object that contains the activity
log messages that are associated with the current message
flow.
|
int |
getAdditionalInstances()
Returns the number of additional thread instances that are allocated
to the message flow.
|
protected java.util.Properties |
getBasicProperties(boolean waitIfNotUpdated)
Returns a filtered list of the properties table associated with the
current object, filtered to basic properties only.
|
int |
getCommitCount()
Returns the configured value of the "commit count" parameter, which
is the number of MQ messages to process before a syncpoint is taken.
|
int |
getCommitInterval()
Returns the configured value of the commit interval parameter, which is the
time in milliseconds between MQ message commits.
|
ConfigurationObjectType |
getConfigurationObjectType()
Returns the ConfigurationObjectType associated
with this AdministeredObject type.
|
boolean |
getCoordinatedTransaction()
Describes whether message flows should participate as part of a
co-ordinated transaction.
|
MessageFlowProxy.PolicySetBindingsName[] |
getDeployedPolicySetBindingsNames()
Asks the broker to return the names of the PolicySetBindings in use by this message flow.
|
MessageFlowProxy.PolicySetName[] |
getDeployedPolicySetNames()
Return the names of the PolicySets in use by this message flow.
|
java.lang.String |
getFileExtension()
Returns the file extension relevant to message flows, not preceded
by a '.' character.
|
int |
getMaximumRateMsgsPerSec()
Returns the maximum rate for the message flow.
|
MessageFlowProxy.Node |
getNodeByName(java.lang.String name)
Returns the node with the supplied name.
|
java.util.Enumeration<MessageFlowProxy.NodeConnection> |
getNodeConnections()
Returns an Enumeration of the NodeConnection objects that comprise this
flow.
|
java.util.Enumeration<MessageFlowProxy.Node> |
getNodes()
Returns an Enumeration of the Node objects that comprise this
flow.
|
int |
getNotificationThresholdMsgsPerSec()
Returns the notification threshold for the message flow.
|
java.lang.String |
getStartMode()
Returns the current value of start mode for this message flow
|
java.lang.String |
getStatisticsAccountingOrigin(boolean isSnapshot)
Returns the accounting origin for the message flow.
|
boolean |
getStatisticsEnabled(boolean isSnapshot)
Returns true only if statistics gathering is enabled for the message flow.
|
int |
getStatisticsNodeDetailLevel(boolean isSnapshot)
Returns the node statistics detail level for the message flow.
|
java.lang.String |
getStatisticsOutputFormat(boolean isSnapshot)
Returns the output format of statistics for the message flow.
|
int |
getStatisticsThreadDetailLevel(boolean isSnapshot)
Returns the thread statistics detail level for the message flow.
|
MessageFlowProxy.UserTrace |
getUserTrace()
Returns the current state of user trace for this message flow
|
java.lang.String |
getWlmPolicy()
Returns the WLM policy for the message flow.
|
boolean |
isRunEnabled()
Returns true only if the message flow is able to run when the
integration server is started.
|
boolean |
isRunning()
Returns true only if the message flow is currently running.
|
void |
resetArchiveStatistics()
Causes the archive of statistics to be reset for the message flow.
|
void |
setAdditionalInstances(int newValue)
Asks the broker to directly set the number of additional thread
instances for this message flow.
|
protected void |
setLocalProperty(java.lang.String key,
java.lang.String value)
We override the setLocalProperty method of AdministeredObject
so that we can clear the node cache if we get new node properties
|
void |
setMaximumRateMsgsPerSec(int newValue)
Asks the broker to directly set the maximum rate
for this message flow.
|
void |
setNotificationThresholdMsgsPerSec(int newValue)
Asks the broker to directly set the notification threshold
for this message flow.
|
void |
setServiceTrace(MessageFlowProxy.UserTrace newTrace)
Configures the service trace setting for the message flow.
|
void |
setStartMode(java.lang.String newStartMode)
Configures the start mode setting for the current flow.
|
void |
setStatisticsAccountingOrigin(boolean isSnapshot,
java.lang.String accountingOrigin)
Configures the accounting origin for the message flow.
|
void |
setStatisticsEnabled(boolean isSnapshot,
boolean isEnabled)
Enables or disables the gathering of statistics for the message flow.
|
void |
setStatisticsNodeDetailLevel(boolean isSnapshot,
int detailLevel)
Sets the detail level of node statistics to gather for the message flow.
|
void |
setStatisticsOutputFormat(boolean isSnapshot,
java.lang.String outputFormat)
Configures the output format of statistics for the message flow.
|
void |
setStatisticsOutputFormat(boolean isSnapshot,
java.lang.String outputFormats,
boolean replaceExistingFormats)
Configures the output format of statistics for the message flow.
|
void |
setStatisticsThreadDetailLevel(boolean isSnapshot,
int detailLevel)
Sets the detail level of thread statistics to gather for the message flow.
|
void |
setUserTrace(MessageFlowProxy.UserTrace newTrace)
Configures the user trace setting for the current flow.
|
void |
setWlmPolicy(java.lang.String newValue)
Asks the broker to directly set the WLM policy
for this message flow.
|
void |
start()
Asks the broker to start the message flow.
|
void |
stop()
Asks the broker to stop the message flow.
|
void |
stop(boolean immediate)
Deprecated.
The immediate flag is ignored. Use stop() instead.
|
void |
stop(BrokerProxy.StopMode stopMode)
Asks the broker to stop the message flow.
|
protected static void |
stopMessageFlow(java.lang.String executionGroup,
java.lang.String application,
java.lang.String lib,
java.lang.String flowName) |
static java.util.Properties |
withName(java.lang.String name)
Returns a new Properties object that has the name attribute set
to the supplied String, and the type attribute to be the name of
the subclass of AdministeredObject being used.
|
static java.util.Properties |
withUUID(java.lang.String uuid)
Returns a new Properties object that has the UUID attribute set
to the supplied String, and the type attribute to be the name of
the subclass of AdministeredObject being used.
|
getBARFileName, getConfigurationObjectTypeOfParent, getDeployProperties, getDeployTime, getElements, getExecutionGroup, getFullName, getKeywords, getKeywordValue, getModifyTime, getNodeTypes, getQueues, getRuntimeProperty, getRuntimePropertyNames, getUserDefinedProperty, getUserDefinedPropertyNames, getVersion, setRuntimeProperties, setRuntimeProperty, setUserDefinedProperty
checkTypeAndBase64DecodePropertyValue, checkTypeAndBase64EncodePropertyValue, clearPredictedNewSubcomponents, createManagedSubcomponent, createManagedSubcomponent, createManagedSubcomponent, createManagedSubcomponent, deleteManagedSubcomponents, deregisterListener, deregisterListener, elements, equals, execute, getAdvancedProperties, getAdvancedProperties, getBasicProperties, getGrandParentUUIDProperties, getLastBIPMessages, getLastCompletionCode, getLastUpdateUser, getLongDescription, getManagedSubcomponent, getManagedSubcomponentFromStringRepresentation, getManagedSubcomponents, getManagedSubcomponents, getManagedSubcomponents, getManagedSubcomponents, getManagedSubcomponentsAsStrings, getManagedSubcomponentsAsStrings, getName, getNumberOfSubcomponents, getParent, getProperties, getProperties, getProperty, getProperty, getProperty, getProperty, getProperty, getPropertyBaseName, getPropertyInt, getPropertyInternal, getRefreshRequired, getRepositoryTimestamp, getShortDescription, getTimeOfLastCompletionCode, getTimeOfLastUpdate, getType, getUUID, getUUIDOfGrandParent, getUUIDOfParent, hasBeenPopulatedByBroker, hasBeenPopulatedByBroker, hasBeenPopulatedByBroker, hasBeenRestrictedByBroker, hasBeenRestrictedByBroker, hasBeenRestrictedByConfigManager, hasBeenRestrictedByConfigManager, hasBeenUpdatedByConfigManager, hasBeenUpdatedByConfigManager, isAUserDefinedObjectDestructor, isAwaitingSubmissionForCreation, isAwaitingSubmissionForDeletion, isDeployed, isLastPropertyIdentifier, isPartOfAPropertyGroup, isShared, predictPropertiesOfNewObject, refresh, refresh, registerListener, registerListener, registerListener, removeLocalProperty, setIsAwaitingSubmissionForCreation, setIsAwaitingSubmissionForDeletion, setLastBIPMessages, setLastCompletionCode, setLongDescription, setName, setProperties, setProperties, setRefreshRequired, setShortDescription, setTimeOfLastUpdate, toString, toVerboseString, unsubscribeFromConfigurationManagerUpdates, validateObjectAndPropertyName, validateServiceObjectAndPropertyName
clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName
protected static final java.lang.String copyright
protected static final java.lang.String sccsid
protected MessageFlowProxy(com.ibm.broker.config.proxy.AdministeredObjectPool aop)
aop
- The pool that will own this object.protected MessageFlowProxy(com.ibm.broker.config.proxy.AdministeredObjectPool aop, ConfigurationObjectType inParentType)
public void start() throws ConfigManagerProxyLoggedException
ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.public void stop(boolean immediate) throws ConfigManagerProxyLoggedException
immediate
- Not usedConfigManagerProxyLoggedException
- if the request to start the
message flow could not be sent to the broker.public void stop() throws ConfigManagerProxyLoggedException
ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.public void stop(BrokerProxy.StopMode stopMode) throws ConfigManagerProxyLoggedException
stopMode
- If set to StopMode.normal, then the message flow will
stop processing new units of work, and any current units of work will
be allowed to complete. If set to StopMode.restartExecutionGroup, then
the integration server will be immediately restarted. When
the integration server has restarted, the message flow will
be in the stopped state.ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.public MessageFlowProxy.UserTrace getUserTrace() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the field could not be determined because
the value has not yet been supplied to from the broker.public void setUserTrace(MessageFlowProxy.UserTrace newTrace) throws ConfigManagerProxyLoggedException
Configures the user trace setting for the current flow.
newTrace
- One of:
ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.public void setServiceTrace(MessageFlowProxy.UserTrace newTrace) throws ConfigManagerProxyLoggedException
newTrace
- One of:
ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker.public java.lang.String getStartMode() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the field could not be determined because
the value has not yet been supplied to from the broker.public void setStartMode(java.lang.String newStartMode) throws ConfigManagerProxyLoggedException
Configures the start mode setting for the current flow.
newStartMode
- One of:
ConfigManagerProxyLoggedException
public void clearRecordedTestData() throws ConfigManagerProxyPropertyNotInitializedException
public boolean isRunning() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the run state could not be determined from
the broker.public boolean isRunEnabled() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the run state could not be determined from
the broker.public int getAdditionalInstances() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public void setAdditionalInstances(int newValue) throws ConfigManagerProxyLoggedException
newValue
- New number of additional threadsConfigManagerProxyLoggedException
- if the request could not
be sent to the broker.public java.lang.String getWlmPolicy() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public void setWlmPolicy(java.lang.String newValue) throws ConfigManagerProxyLoggedException
newValue
- The WLM policy to use.ConfigManagerProxyLoggedException
- if the request could not
be sent to the broker.public int getNotificationThresholdMsgsPerSec() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public void setNotificationThresholdMsgsPerSec(int newValue) throws ConfigManagerProxyLoggedException
newValue
- New notification threshold in messages per secondConfigManagerProxyLoggedException
- if the request could not
be sent to the broker.public int getMaximumRateMsgsPerSec() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public void setMaximumRateMsgsPerSec(int newValue) throws ConfigManagerProxyLoggedException
newValue
- New maximum rate in messages per secondConfigManagerProxyLoggedException
- if the request could not
be sent to the broker.public int getCommitCount() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public int getCommitInterval() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public boolean getCoordinatedTransaction() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public java.lang.String getFileExtension()
getFileExtension
in interface DeployableObject
getFileExtension
in class FlowProxy
DeployableObject.getFileExtension()
public boolean fullNameMatches(java.lang.String fileName) throws ConfigManagerProxyPropertyNotInitializedException
fullNameMatches
in interface DeployedObject
fullNameMatches
in class FlowProxy
ConfigManagerProxyLoggedException
- if the parent
object is not immediately available and has to be
requested from the broker, but the
request could not be sent to the broker.ConfigManagerProxyPropertyNotInitializedException
protected java.util.Properties getBasicProperties(boolean waitIfNotUpdated) throws ConfigManagerProxyPropertyNotInitializedException
getBasicProperties
in class AdministeredObject
waitIfNotUpdated
- Only if this value is true, the method
will pause until the object has received at least one update from
the broker. If an update is not received before the timeout specified
in BrokerProxy.setRetryCharacteristics() is reached,
AdministeredObject.hasBeenPopulatedByBroker() will return false and the returned
Properties object will contain a much smaller set of properties,
that the IBM Integration API (CMP) has derived from other
sources.ConfigManagerProxyPropertyNotInitializedException
public ConfigurationObjectType getConfigurationObjectType()
getConfigurationObjectType
in class FlowProxy
public void enableBasicStatistics() throws ConfigManagerProxyLoggedException
public void setStatisticsEnabled(boolean isSnapshot, boolean isEnabled) throws ConfigManagerProxyLoggedException
isSnapshot
- If true, the configuration of snapshot statistics
will be modified. If false, the parameter for archive statistics
will be modified.isEnabled
- If true, statistics gathering will be enabled.
If false, statistics gathering will be disabled.ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.public boolean getStatisticsEnabled(boolean isSnapshot) throws ConfigManagerProxyPropertyNotInitializedException
isSnapshot
- If true, the configuration of snapshot statistics
will be returned. If false, the parameter for archive statistics
will be returned.ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public void setStatisticsNodeDetailLevel(boolean isSnapshot, int detailLevel) throws ConfigManagerProxyLoggedException, java.lang.IllegalArgumentException
isSnapshot
- If true, the configuration of snapshot statistics
will be modified. If false, the parameter for archive statistics
will be modified.detailLevel
- Level of detail to configure: 0=none; 1=basic; 2=advanced.ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.java.lang.IllegalArgumentException
- if the supplied parameter is not
0, 1 or 2.public int getStatisticsNodeDetailLevel(boolean isSnapshot) throws ConfigManagerProxyPropertyNotInitializedException
isSnapshot
- If true, the configuration of snapshot statistics
will be returned. If false, the parameter for archive statistics
will be returned.ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public void setStatisticsOutputFormat(boolean isSnapshot, java.lang.String outputFormat) throws ConfigManagerProxyLoggedException, java.lang.IllegalArgumentException
isSnapshot
- If true, the configuration of snapshot statistics
will be modified. If false, the parameter for archive statistics
will be modified.outputFormat
- Valid formats are:ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.java.lang.IllegalArgumentException
- if the supplied outputFormat
parameter is not valid.public void setStatisticsOutputFormat(boolean isSnapshot, java.lang.String outputFormats, boolean replaceExistingFormats) throws ConfigManagerProxyLoggedException, java.lang.IllegalArgumentException
isSnapshot
- If true, the configuration of snapshot statistics
will be modified. If false, the parameter for archive statistics
will be modified.outputFormats
- Valid formats are:ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.java.lang.IllegalArgumentException
- if the supplied outputFormat
parameter is not valid.public java.lang.String getStatisticsOutputFormat(boolean isSnapshot) throws ConfigManagerProxyPropertyNotInitializedException
isSnapshot
- If true, the configuration of snapshot statistics
will be returned. If false, the parameter for archive statistics
will be returned.ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public void setStatisticsThreadDetailLevel(boolean isSnapshot, int detailLevel) throws ConfigManagerProxyLoggedException, java.lang.IllegalArgumentException
isSnapshot
- If true, the configuration of snapshot statistics
will be modified. If false, the parameter for archive statistics
will be modified.detailLevel
- Level of detail to configure: 0=none; 1=basic.ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.java.lang.IllegalArgumentException
- if the supplied parameter is not
0 or 1.public int getStatisticsThreadDetailLevel(boolean isSnapshot) throws ConfigManagerProxyPropertyNotInitializedException
isSnapshot
- If true, the configuration of snapshot statistics
will be returned. If false, the parameter for archive statistics
will be returned.ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public void setStatisticsAccountingOrigin(boolean isSnapshot, java.lang.String accountingOrigin) throws ConfigManagerProxyLoggedException
isSnapshot
- If true, the configuration of snapshot statistics
will be modified. If false, the parameter for archive statistics
will be modified.accountingOrigin
- New accounting origin for the message flow.ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.public java.lang.String getStatisticsAccountingOrigin(boolean isSnapshot) throws ConfigManagerProxyPropertyNotInitializedException
isSnapshot
- If true, the configuration of snapshot statistics
will be returned. If false, the parameter for archive statistics
will be returned.ConfigManagerProxyPropertyNotInitializedException
public void resetArchiveStatistics() throws ConfigManagerProxyLoggedException
ConfigManagerProxyLoggedException
- if the request could not be
sent to the broker. If synchronous updates have been enabled using
BrokerProxy.setSynchronous(), subclasses of this exception type will
also be thrown if the request is rejected by the broker, or if the
request is not processed before a timeout occurs.public ActivityLogProxy getActivityLog() throws ConfigManagerProxyPropertyNotInitializedException, ConfigManagerProxyLoggedException
ConfigManagerProxyPropertyNotInitializedException
- if the log could not be retrieved because
the information was not supplied from the broker before a
timeout occurred.ConfigManagerProxyLoggedException
- if the log could not be created because
the information was not supplied from the broker before a
timeout occurred.protected static void stopMessageFlow(java.lang.String executionGroup, java.lang.String application, java.lang.String lib, java.lang.String flowName) throws ConfigManagerProxyLoggedException, ConfigManagerProxyPropertyNotInitializedException
public MessageFlowProxy.PolicySetName[] getDeployedPolicySetNames() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public MessageFlowProxy.PolicySetBindingsName[] getDeployedPolicySetBindingsNames() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.protected void setLocalProperty(java.lang.String key, java.lang.String value)
setLocalProperty
in class AdministeredObject
key
- The name of the property to set.
Use the AttributeConstants.*_PROPERTY constants here.value
- The value to set the property to.public java.util.Enumeration<MessageFlowProxy.Node> getNodes() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public MessageFlowProxy.Node getNodeByName(java.lang.String name) throws ConfigManagerProxyPropertyNotInitializedException
name
- node nameConfigManagerProxyPropertyNotInitializedException
- if the node list could not be determined because
information was not supplied from the broker before a
timeout occurred.public java.util.Enumeration<MessageFlowProxy.NodeConnection> getNodeConnections() throws ConfigManagerProxyPropertyNotInitializedException
ConfigManagerProxyPropertyNotInitializedException
- if the value of the parameter could not be determined because
the information was not supplied from the broker before a
timeout occurred.public static java.util.Properties withUUID(java.lang.String uuid)
public static java.util.Properties withName(java.lang.String name)