Class JPPFNodeAdminMBeanForwarder
java.lang.Object
org.jppf.management.forwarding.AbstractMBeanForwarder
org.jppf.management.forwarding.generated.JPPFNodeAdminMBeanForwarder
Forwarding proxy for the
JPPFNodeAdminMBean MBean.
MBean description: management and monitoring of a JPPF node.- Since:
- 6.2
-
Constructor Summary
ConstructorsConstructorDescriptionInitialize this proxy. -
Method Summary
Modifier and TypeMethodDescriptioncancelJob(NodeSelector selector, String jobUuid, Boolean requeue) Invoke thecancelJoboperation for all selected nodes (ancel the job with the specified uuid).cancelPendingAction(NodeSelector selector) Invoke thecancelPendingActionoperation for all selected nodes (cancel a previous deferred shutdown or restart request, if any).getDelegationModel(NodeSelector selector) Get the value of theDelegationModelattribute for all selected nodes (the current class loader delegation model for the node).pendingAction(NodeSelector selector) Invoke thependingActionoperation for all selected nodes (determine wether a deffered shutdwon or restartd was requested and not yet performed for the node).reconnect(NodeSelector selector, Boolean interruptIfRunning) Invoke thereconnectoperation for all selected nodes (force the node to reconnect without restarting, specifying whether to wait for executing tasks to complete).resetTaskCounter(NodeSelector selector) Invoke theresetTaskCounteroperation for all selected nodes (reset the node's executed tasks counter to zero).restart(NodeSelector selector) Invoke therestartoperation for all selected nodes (restart the node unconditionally).restart(NodeSelector selector, Boolean interruptIfRunning) Invoke therestartoperation for all selected nodes (restart the node, specifying whether to wait for executing tasks to complete).setDelegationModel(NodeSelector selector, DelegationModel value) Set the value of theDelegationModelattribute on all selected nodes (the current class loader delegation model for the node).setTaskCounter(NodeSelector selector, Integer value) Set the value of theTaskCounterattribute on all selected nodes (reset the node's executed tasks counter to the specified value).shutdown(NodeSelector selector) Invoke theshutdownoperation for all selected nodes (shutdown the node unconditionally).shutdown(NodeSelector selector, Boolean interruptIfRunning) Invoke theshutdownoperation for all selected nodes (shutdown the node, specifying whether to wait for executing tasks to complete).state(NodeSelector selector) Invoke thestateoperation for all selected nodes (get the latest state information from the node).systemInformation(NodeSelector selector) Invoke thesystemInformationoperation for all selected nodes (get detailed information on the system where the JPPF server or node is runnning: environement variables, JVM system properties, JPPF configuration, runtime information, storage details, network interfaces, statistics).updateConfiguration(NodeSelector selector, Map<Object, Object> configUpdates, Boolean restartNode) Invoke theupdateConfigurationoperation for all selected nodes (update the configuration properties of the node).updateConfiguration(NodeSelector selector, Map<Object, Object> cfgUpdates, Boolean restartNode, Boolean interruptIfRunning) Invoke theupdateConfigurationoperation for all selected nodes (update the configuration properties of the node).updateThreadPoolSize(NodeSelector selector, Integer poolSize) Invoke theupdateThreadPoolSizeoperation for all selected nodes (set the size of the node's thread pool).updateThreadsPriority(NodeSelector selector, Integer newPriority) Invoke theupdateThreadsPriorityoperation for all selected nodes (update the priority of all processing threads).Methods inherited from class org.jppf.management.forwarding.AbstractMBeanForwarder
addNotificationListener, addNotificationListener, getAttribute, invoke, invoke, removeAllNotificationListeners, removeNotificationListener, setAttribute
-
Constructor Details
-
JPPFNodeAdminMBeanForwarder
Initialize this proxy.- Parameters:
jmx- aJMXDriverConnectionWrapperinstance.- Throws:
Exception- if any error occurs..
-
-
Method Details
-
getDelegationModel
public ResultsMap<String,DelegationModel> getDelegationModel(NodeSelector selector) throws Exception Get the value of theDelegationModelattribute for all selected nodes (the current class loader delegation model for the node).- Parameters:
selector- aNodeSelectorinstance.- Returns:
- a mapping of node uuids to
DelegationModelinstances. - Throws:
Exception- if any error occurs.
-
setDelegationModel
public ResultsMap<String,Void> setDelegationModel(NodeSelector selector, DelegationModel value) throws Exception Set the value of theDelegationModelattribute on all selected nodes (the current class loader delegation model for the node).- Parameters:
selector- aNodeSelectorinstance.value- the value to set, aDelegationModelinstance.- Returns:
- a mapping of node uuids to invocation results which may either be null or an exception.
- Throws:
Exception- if any error occurs.
-
setTaskCounter
public ResultsMap<String,Void> setTaskCounter(NodeSelector selector, Integer value) throws Exception Set the value of theTaskCounterattribute on all selected nodes (reset the node's executed tasks counter to the specified value).- Parameters:
selector- aNodeSelectorinstance.value- the value to set, aIntegerinstance.- Returns:
- a mapping of node uuids to invocation results which may either be null or an exception.
- Throws:
Exception- if any error occurs.
-
shutdown
Invoke theshutdownoperation for all selected nodes (shutdown the node unconditionally).- Parameters:
selector- aNodeSelectorinstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
shutdown
public ResultsMap<String,Void> shutdown(NodeSelector selector, Boolean interruptIfRunning) throws Exception Invoke theshutdownoperation for all selected nodes (shutdown the node, specifying whether to wait for executing tasks to complete).- Parameters:
selector- aNodeSelectorinstance.interruptIfRunning- aBooleaninstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
state
Invoke thestateoperation for all selected nodes (get the latest state information from the node).- Parameters:
selector- aNodeSelectorinstance.- Returns:
- a mapping of node uuids to objects that wrap either a [@link JPPFNodeState} or an exeption.
- Throws:
Exception- if any error occurs.
-
pendingAction
Invoke thependingActionoperation for all selected nodes (determine wether a deffered shutdwon or restartd was requested and not yet performed for the node).- Parameters:
selector- aNodeSelectorinstance.- Returns:
- a mapping of node uuids to objects that wrap either a [@link NodePendingAction} or an exeption.
- Throws:
Exception- if any error occurs.
-
restart
public ResultsMap<String,Void> restart(NodeSelector selector, Boolean interruptIfRunning) throws Exception Invoke therestartoperation for all selected nodes (restart the node, specifying whether to wait for executing tasks to complete).- Parameters:
selector- aNodeSelectorinstance.interruptIfRunning- aBooleaninstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
restart
Invoke therestartoperation for all selected nodes (restart the node unconditionally).- Parameters:
selector- aNodeSelectorinstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
cancelJob
public ResultsMap<String,Void> cancelJob(NodeSelector selector, String jobUuid, Boolean requeue) throws Exception Invoke thecancelJoboperation for all selected nodes (ancel the job with the specified uuid).- Parameters:
selector- aNodeSelectorinstance.jobUuid- aStringinstance.requeue- aBooleaninstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
cancelPendingAction
Invoke thecancelPendingActionoperation for all selected nodes (cancel a previous deferred shutdown or restart request, if any).- Parameters:
selector- aNodeSelectorinstance.- Returns:
- a mapping of node uuids to objects that wrap either a [@link Boolean} or an exeption.
- Throws:
Exception- if any error occurs.
-
updateThreadsPriority
public ResultsMap<String,Void> updateThreadsPriority(NodeSelector selector, Integer newPriority) throws Exception Invoke theupdateThreadsPriorityoperation for all selected nodes (update the priority of all processing threads).- Parameters:
selector- aNodeSelectorinstance.newPriority- aIntegerinstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
reconnect
public ResultsMap<String,Void> reconnect(NodeSelector selector, Boolean interruptIfRunning) throws Exception Invoke thereconnectoperation for all selected nodes (force the node to reconnect without restarting, specifying whether to wait for executing tasks to complete).- Parameters:
selector- aNodeSelectorinstance.interruptIfRunning- aBooleaninstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
resetTaskCounter
Invoke theresetTaskCounteroperation for all selected nodes (reset the node's executed tasks counter to zero).- Parameters:
selector- aNodeSelectorinstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
updateThreadPoolSize
public ResultsMap<String,Void> updateThreadPoolSize(NodeSelector selector, Integer poolSize) throws Exception Invoke theupdateThreadPoolSizeoperation for all selected nodes (set the size of the node's thread pool).- Parameters:
selector- aNodeSelectorinstance.poolSize- aIntegerinstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
updateConfiguration
public ResultsMap<String,Void> updateConfiguration(NodeSelector selector, Map<Object, Object> cfgUpdates, Boolean restartNode, Boolean interruptIfRunning) throws ExceptionInvoke theupdateConfigurationoperation for all selected nodes (update the configuration properties of the node).- Parameters:
selector- aNodeSelectorinstance.cfgUpdates- aMapinstance.restartNode- aBooleaninstance.interruptIfRunning- aBooleaninstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
updateConfiguration
public ResultsMap<String,Void> updateConfiguration(NodeSelector selector, Map<Object, Object> configUpdates, Boolean restartNode) throws ExceptionInvoke theupdateConfigurationoperation for all selected nodes (update the configuration properties of the node).- Parameters:
selector- aNodeSelectorinstance.configUpdates- aMapinstance.restartNode- aBooleaninstance.- Returns:
- a mapping of node uuids to objects that wrap either
nullor an exeption. - Throws:
Exception- if any error occurs.
-
systemInformation
public ResultsMap<String,JPPFSystemInformation> systemInformation(NodeSelector selector) throws Exception Invoke thesystemInformationoperation for all selected nodes (get detailed information on the system where the JPPF server or node is runnning: environement variables, JVM system properties, JPPF configuration, runtime information, storage details, network interfaces, statistics).- Parameters:
selector- aNodeSelectorinstance.- Returns:
- a mapping of node uuids to objects that wrap either a [@link JPPFSystemInformation} or an exeption.
- Throws:
Exception- if any error occurs.
-