Package org.jppf.management.forwarding

Class NodeForwarding

java.lang.Object

javax.management.NotificationBroadcasterSupport

org.jppf.management.forwarding.AbstractNodeForwarding

org.jppf.management.forwarding.NodeForwarding

All Implemented Interfaces:

Serializable, NotificationBroadcaster, NotificationEmitter, org.jppf.management.forwarding.ForwardingNotficationEmitter, org.jppf.management.forwarding.NodeForwardingMBean

public class NodeForwarding
extends AbstractNodeForwarding
implements org.jppf.management.forwarding.NodeForwardingMBean

Implementation of the JPPFNodeForwardingMBean interface.

Author:

Laurent Cohen

See Also:

• Serialized Form

Field Summary

Fields inherited from interface org.jppf.management.forwarding.NodeForwardingMBean

MBEAN_NAME

Constructor Summary

Constructors

Constructor	Description
NodeForwarding(JPPFDriver driver)	Initialize this MBean implementation.

Method Summary

Modifier and Type	Method	Description
org.jppf.utils.ResultsMap<String,Void>	cancelJob(org.jppf.management.NodeSelector selector, String jobUuid, Boolean requeue)
<E> org.jppf.utils.ResultsMap<String,E>	forwardGetAttribute(org.jppf.management.NodeSelector selector, String name, String attribute)
<E> org.jppf.utils.ResultsMap<String,E>	forwardInvoke(org.jppf.management.NodeSelector selector, String name, String methodName)
<E> org.jppf.utils.ResultsMap<String,E>	forwardInvoke(org.jppf.management.NodeSelector selector, String name, String methodName, Object[] params, String[] signature)
org.jppf.utils.ResultsMap<String,Void>	forwardSetAttribute(org.jppf.management.NodeSelector selector, String name, String attribute, Object value)
org.jppf.utils.ResultsMap<String,Void>	gc(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,org.jppf.classloader.DelegationModel>	getDelegationModel(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,Integer>	getNbSlaves(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,org.jppf.management.diagnostics.HealthSnapshot>	healthSnapshot(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,String>	heapDump(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,Void>	provisionSlaveNodes(org.jppf.management.NodeSelector selector, int nbNodes)
org.jppf.utils.ResultsMap<String,Void>	provisionSlaveNodes(org.jppf.management.NodeSelector selector, int nbNodes, boolean interruptIfRunning)
org.jppf.utils.ResultsMap<String,Void>	provisionSlaveNodes(org.jppf.management.NodeSelector selector, int nbNodes, boolean interruptIfRunning, org.jppf.utils.TypedProperties configOverrides)
org.jppf.utils.ResultsMap<String,Void>	provisionSlaveNodes(org.jppf.management.NodeSelector selector, int nbNodes, org.jppf.utils.TypedProperties configOverrides)
org.jppf.utils.ResultsMap<String,Void>	reconnect(org.jppf.management.NodeSelector selector, Boolean interruptIfRunning)
org.jppf.utils.ResultsMap<String,Void>	resetTaskCounter(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,Void>	restart(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,Void>	restart(org.jppf.management.NodeSelector selector, Boolean interruptIfRunning)
org.jppf.utils.ResultsMap<String,Void>	setDelegationModel(org.jppf.management.NodeSelector selector, org.jppf.classloader.DelegationModel model)
org.jppf.utils.ResultsMap<String,Void>	setTaskCounter(org.jppf.management.NodeSelector selector, Integer n)
org.jppf.utils.ResultsMap<String,Void>	shutdown(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,Void>	shutdown(org.jppf.management.NodeSelector selector, Boolean interruptIfRunning)
org.jppf.utils.ResultsMap<String,org.jppf.management.JPPFNodeState>	state(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,org.jppf.management.JPPFSystemInformation>	systemInformation(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,org.jppf.management.diagnostics.ThreadDump>	threadDump(org.jppf.management.NodeSelector selector)
org.jppf.utils.ResultsMap<String,Void>	updateConfiguration(org.jppf.management.NodeSelector selector, Map<Object,Object> configOverrides, Boolean restart)
org.jppf.utils.ResultsMap<String,Void>	updateConfiguration(org.jppf.management.NodeSelector selector, Map<Object,Object> configOverrides, Boolean restart, Boolean interruptIfRunning)
org.jppf.utils.ResultsMap<String,Void>	updateThreadPoolSize(org.jppf.management.NodeSelector selector, Integer size)
org.jppf.utils.ResultsMap<String,Void>	updateThreadsPriority(org.jppf.management.NodeSelector selector, Integer newPriority)

Methods inherited from class org.jppf.management.forwarding.AbstractNodeForwarding

registerForwardingNotificationListener, sendNotification, unregisterForwardingNotificationListener

Methods inherited from class javax.management.NotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, removeNotificationListener, removeNotificationListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jppf.management.forwarding.ForwardingNotficationEmitter

registerForwardingNotificationListener, unregisterForwardingNotificationListener

Methods inherited from interface javax.management.NotificationBroadcaster

addNotificationListener, getNotificationInfo, removeNotificationListener

Methods inherited from interface javax.management.NotificationEmitter

removeNotificationListener

Constructor Details

NodeForwarding

public NodeForwarding(JPPFDriver driver)

Initialize this MBean implementation.

Parameters:

driver - reference to the JPPF driver.

Method Details

forwardInvoke

public <E> org.jppf.utils.ResultsMap<String,E> forwardInvoke(org.jppf.management.NodeSelector selector,
 String name,
 String methodName,
 Object[] params,
 String[] signature)
                                                      throws Exception

Specified by:

forwardInvoke in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

forwardInvoke

public <E> org.jppf.utils.ResultsMap<String,E> forwardInvoke(org.jppf.management.NodeSelector selector,
 String name,
 String methodName)
                                                      throws Exception

Specified by:

forwardInvoke in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

forwardGetAttribute

public <E> org.jppf.utils.ResultsMap<String,E> forwardGetAttribute(org.jppf.management.NodeSelector selector,
 String name,
 String attribute)
                                                            throws Exception

Specified by:

forwardGetAttribute in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

forwardSetAttribute

public org.jppf.utils.ResultsMap<String,Void> forwardSetAttribute(org.jppf.management.NodeSelector selector,
 String name,
 String attribute,
 Object value)
                                                           throws Exception

Specified by:

forwardSetAttribute in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

state

public org.jppf.utils.ResultsMap<String,org.jppf.management.JPPFNodeState> state(org.jppf.management.NodeSelector selector)
                                                                          throws Exception

Specified by:

state in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

updateThreadPoolSize

public org.jppf.utils.ResultsMap<String,Void> updateThreadPoolSize(org.jppf.management.NodeSelector selector,
 Integer size)
                                                            throws Exception

Specified by:

updateThreadPoolSize in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

updateThreadsPriority

public org.jppf.utils.ResultsMap<String,Void> updateThreadsPriority(org.jppf.management.NodeSelector selector,
 Integer newPriority)
                                                             throws Exception

Specified by:

updateThreadsPriority in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

restart

public org.jppf.utils.ResultsMap<String,Void> restart(org.jppf.management.NodeSelector selector)
                                               throws Exception

Specified by:

restart in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

restart

public org.jppf.utils.ResultsMap<String,Void> restart(org.jppf.management.NodeSelector selector,
 Boolean interruptIfRunning)
                                               throws Exception

Specified by:

restart in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

shutdown

public org.jppf.utils.ResultsMap<String,Void> shutdown(org.jppf.management.NodeSelector selector)
                                                throws Exception

Specified by:

shutdown in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

shutdown

public org.jppf.utils.ResultsMap<String,Void> shutdown(org.jppf.management.NodeSelector selector,
 Boolean interruptIfRunning)
                                                throws Exception

Specified by:

shutdown in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

reconnect

public org.jppf.utils.ResultsMap<String,Void> reconnect(org.jppf.management.NodeSelector selector,
 Boolean interruptIfRunning)
                                                 throws Exception

Specified by:

reconnect in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

resetTaskCounter

public org.jppf.utils.ResultsMap<String,Void> resetTaskCounter(org.jppf.management.NodeSelector selector)
                                                        throws Exception

Specified by:

resetTaskCounter in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

setTaskCounter

public org.jppf.utils.ResultsMap<String,Void> setTaskCounter(org.jppf.management.NodeSelector selector,
 Integer n)
                                                      throws Exception

Specified by:

setTaskCounter in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

updateConfiguration

public org.jppf.utils.ResultsMap<String,Void> updateConfiguration(org.jppf.management.NodeSelector selector,
 Map<Object,Object> configOverrides,
 Boolean restart,
 Boolean interruptIfRunning)
                                                           throws Exception

Specified by:

updateConfiguration in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

updateConfiguration

public org.jppf.utils.ResultsMap<String,Void> updateConfiguration(org.jppf.management.NodeSelector selector,
 Map<Object,Object> configOverrides,
 Boolean restart)
                                                           throws Exception

Specified by:

updateConfiguration in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

cancelJob

public org.jppf.utils.ResultsMap<String,Void> cancelJob(org.jppf.management.NodeSelector selector,
 String jobUuid,
 Boolean requeue)
                                                 throws Exception

Specified by:

cancelJob in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

getDelegationModel

public org.jppf.utils.ResultsMap<String,org.jppf.classloader.DelegationModel> getDelegationModel(org.jppf.management.NodeSelector selector)
                                                                                          throws Exception

Specified by:

getDelegationModel in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

setDelegationModel

public org.jppf.utils.ResultsMap<String,Void> setDelegationModel(org.jppf.management.NodeSelector selector,
 org.jppf.classloader.DelegationModel model)
                                                          throws Exception

Specified by:

setDelegationModel in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

systemInformation

public org.jppf.utils.ResultsMap<String,org.jppf.management.JPPFSystemInformation> systemInformation(org.jppf.management.NodeSelector selector)
                                                                                              throws Exception

Specified by:

systemInformation in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

healthSnapshot

public org.jppf.utils.ResultsMap<String,org.jppf.management.diagnostics.HealthSnapshot> healthSnapshot(org.jppf.management.NodeSelector selector)
                                                                                                throws Exception

Specified by:

healthSnapshot in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

gc

public org.jppf.utils.ResultsMap<String,Void> gc(org.jppf.management.NodeSelector selector)
                                          throws Exception

Specified by:

gc in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

heapDump

public org.jppf.utils.ResultsMap<String,String> heapDump(org.jppf.management.NodeSelector selector)
                                                  throws Exception

Specified by:

heapDump in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

threadDump

public org.jppf.utils.ResultsMap<String,org.jppf.management.diagnostics.ThreadDump> threadDump(org.jppf.management.NodeSelector selector)
                                                                                        throws Exception

Specified by:

threadDump in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

getNbSlaves

public org.jppf.utils.ResultsMap<String,Integer> getNbSlaves(org.jppf.management.NodeSelector selector)
                                                      throws Exception

Specified by:

getNbSlaves in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

provisionSlaveNodes

public org.jppf.utils.ResultsMap<String,Void> provisionSlaveNodes(org.jppf.management.NodeSelector selector,
 int nbNodes)
                                                           throws Exception

Specified by:

provisionSlaveNodes in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

provisionSlaveNodes

public org.jppf.utils.ResultsMap<String,Void> provisionSlaveNodes(org.jppf.management.NodeSelector selector,
 int nbNodes,
 boolean interruptIfRunning)
                                                           throws Exception

Specified by:

provisionSlaveNodes in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

provisionSlaveNodes

public org.jppf.utils.ResultsMap<String,Void> provisionSlaveNodes(org.jppf.management.NodeSelector selector,
 int nbNodes,
 org.jppf.utils.TypedProperties configOverrides)
                                                           throws Exception

Specified by:

provisionSlaveNodes in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception

provisionSlaveNodes

public org.jppf.utils.ResultsMap<String,Void> provisionSlaveNodes(org.jppf.management.NodeSelector selector,
 int nbNodes,
 boolean interruptIfRunning,
 org.jppf.utils.TypedProperties configOverrides)
                                                           throws Exception

Specified by:

provisionSlaveNodes in interface org.jppf.management.forwarding.NodeForwardingMBean

Throws:

Exception