org.ow2.proactive.resourcemanager.common.util

Class RMListenerProxy

java.lang.Object

org.ow2.proactive.resourcemanager.frontend.RMGroupEventListener

org.ow2.proactive.resourcemanager.common.util.RMListenerProxy

All Implemented Interfaces:

RMEventListener

Direct Known Subclasses:

RMProxyUserInterface

public class RMListenerProxy
extends RMGroupEventListener

This class adds a cache mechanism that maintains the RMInitialState state of the remote resource manager. You must init the proxy by calling the init(String, Credentials) method after having created it

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicLong	counter
protected Credentials	credentials
protected JMXClientHelper	jmxClient
protected org.apache.log4j.Logger	logger
static long	MONITORING_INTERFACE_TIMEOUT
protected JMXConnector	nodeConnector
protected String	nodeConnectorUrl
protected RMAuthentication	rmAuth
protected RMInitialState	rmInitialState
protected RMEventType	RMstate
protected ResourceManager	target

Constructor Summary

Constructors

Constructor and Description
RMListenerProxy()

Method Summary

Modifier and Type	Method and Description
org.objectweb.proactive.core.util.wrapper.BooleanWrapper	disconnect()
String	getNodeMBeanHistory(String nodeJmxUrl, String objectName, List<String> attrs, String range)
Object	getNodeMBeanInfo(String nodeJmxUrl, String objectName, List<String> attrs) Retrieves attributes of the specified mbean.
Object	getNodeMBeansHistory(String nodeJmxUrl, String objectNames, List<String> attrs, String range)
Object	getNodeMBeansInfo(String nodeJmxUrl, String objectNames, List<String> attrs) Retrieves attributes of the specified mbeans.
RMStateDelta	getRMStateDelta(long filter)
RMStateFull	getRMStateFull()
boolean	init(String url, CredData credData)
boolean	init(String url, Credentials credentials)
void	nodeEvent(RMNodeEvent event) new node available in RM.
void	nodeSourceEvent(RMNodeSourceEvent event) new node source available in RM.
void	rmEvent(RMEvent event) RM is shutting down

Methods inherited from class org.ow2.proactive.resourcemanager.frontend.RMGroupEventListener

notify

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected org.apache.log4j.Logger logger

MONITORING_INTERFACE_TIMEOUT

public static final long MONITORING_INTERFACE_TIMEOUT

See Also:

Constant Field Values

rmAuth

protected RMAuthentication rmAuth

rmInitialState

protected RMInitialState rmInitialState

RMstate

protected RMEventType RMstate

credentials

protected Credentials credentials

target

protected ResourceManager target

jmxClient

protected JMXClientHelper jmxClient

nodeConnector

protected JMXConnector nodeConnector

nodeConnectorUrl

protected String nodeConnectorUrl

counter

protected AtomicLong counter

Constructor Detail

RMListenerProxy

public RMListenerProxy()

Method Detail

init

public boolean init(String url,
                    CredData credData)
             throws RMException,
                    KeyException,
                    LoginException

Throws:

RMException

KeyException

LoginException

init

public boolean init(String url,
                    Credentials credentials)
             throws RMException,
                    KeyException,
                    LoginException

Throws:

RMException

KeyException

LoginException

disconnect

public org.objectweb.proactive.core.util.wrapper.BooleanWrapper disconnect()

See Also:

ResourceManager.disconnect()

rmEvent

public void rmEvent(RMEvent event)

Description copied from interface: RMEventListener

RM is shutting down

Parameters:

event - object representing the event.

See Also:

RMEventListener.rmEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent)

nodeSourceEvent

public void nodeSourceEvent(RMNodeSourceEvent event)

Description copied from interface: RMEventListener

new node source available in RM.

Parameters:

event - node source event containing new NodeSource properties.

See Also:

RMEventListener.nodeSourceEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeSourceEvent)

nodeEvent

public void nodeEvent(RMNodeEvent event)

Description copied from interface: RMEventListener

new node available in RM.

Parameters:

event - node event containing new RMNode properties.

See Also:

RMEventListener.nodeEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent)

getRMStateDelta

public RMStateDelta getRMStateDelta(long filter)

getRMStateFull

public RMStateFull getRMStateFull()

getNodeMBeanInfo

public Object getNodeMBeanInfo(String nodeJmxUrl,
                               String objectName,
                               List<String> attrs)
                        throws IOException,
                               InstanceNotFoundException,
                               IntrospectionException,
                               MalformedObjectNameException,
                               ReflectionException,
                               NullPointerException

Retrieves attributes of the specified mbean.

Parameters:

nodeJmxUrl - mbean server url

objectName - name of mbean

attrs - set of mbean attributes

Returns:

mbean attributes values

Throws:

IOException

InstanceNotFoundException

IntrospectionException

MalformedObjectNameException

ReflectionException

NullPointerException

getNodeMBeanHistory

public String getNodeMBeanHistory(String nodeJmxUrl,
                                  String objectName,
                                  List<String> attrs,
                                  String range)
                           throws IOException,
                                  MalformedObjectNameException,
                                  IntrospectionException,
                                  InstanceNotFoundException,
                                  ReflectionException,
                                  MBeanException

Throws:

IOException

MalformedObjectNameException

IntrospectionException

InstanceNotFoundException

ReflectionException

MBeanException

getNodeMBeansInfo

public Object getNodeMBeansInfo(String nodeJmxUrl,
                                String objectNames,
                                List<String> attrs)
                         throws IOException,
                                InstanceNotFoundException,
                                IntrospectionException,
                                MalformedObjectNameException,
                                ReflectionException,
                                NullPointerException

Retrieves attributes of the specified mbeans.

Parameters:

objectNames - mbean names (@see ObjectName format)

nodeJmxUrl - mbean server url

attrs - set of mbean attributes

Returns:

mbean attributes values

Throws:

IOException

InstanceNotFoundException

IntrospectionException

MalformedObjectNameException

ReflectionException

NullPointerException

getNodeMBeansHistory

public Object getNodeMBeansHistory(String nodeJmxUrl,
                                   String objectNames,
                                   List<String> attrs,
                                   String range)
                            throws IOException,
                                   MalformedObjectNameException,
                                   IntrospectionException,
                                   InstanceNotFoundException,
                                   ReflectionException,
                                   MBeanException

Throws:

IOException

MalformedObjectNameException

IntrospectionException

InstanceNotFoundException

ReflectionException

MBeanException