public class RMListenerProxy extends RMGroupEventListener
RMInitialState
state of the
remote resource manager.
You must init the proxy by calling the init(String, Credentials)
method
after having created itModifier 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 org.ow2.proactive.resourcemanager.common.event.RMInitialState |
rmInitialState |
protected org.ow2.proactive.resourcemanager.common.event.RMEventType |
RMstate |
protected ResourceManager |
target |
Constructor and Description |
---|
RMListenerProxy() |
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.
|
org.ow2.proactive.resourcemanager.common.event.dto.RMStateDelta |
getRMStateDelta(long filter) |
org.ow2.proactive.resourcemanager.common.event.dto.RMStateFull |
getRMStateFull() |
boolean |
init(String url,
CredData credData) |
boolean |
init(String url,
Credentials credentials) |
void |
nodeEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent event) |
void |
nodeSourceEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeSourceEvent event) |
void |
rmEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent event) |
notify
protected org.apache.log4j.Logger logger
public static final long MONITORING_INTERFACE_TIMEOUT
protected RMAuthentication rmAuth
protected org.ow2.proactive.resourcemanager.common.event.RMInitialState rmInitialState
protected org.ow2.proactive.resourcemanager.common.event.RMEventType RMstate
protected Credentials credentials
protected ResourceManager target
protected JMXClientHelper jmxClient
protected JMXConnector nodeConnector
protected String nodeConnectorUrl
protected AtomicLong counter
public boolean init(String url, CredData credData) throws org.ow2.proactive.resourcemanager.exception.RMException, KeyException, LoginException
org.ow2.proactive.resourcemanager.exception.RMException
KeyException
LoginException
public boolean init(String url, Credentials credentials) throws org.ow2.proactive.resourcemanager.exception.RMException, KeyException, LoginException
org.ow2.proactive.resourcemanager.exception.RMException
KeyException
LoginException
public org.objectweb.proactive.core.util.wrapper.BooleanWrapper disconnect()
ResourceManager.disconnect()
public void rmEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent event)
RMEventListener.rmEvent(org.ow2.proactive.resourcemanager.common.event.RMEvent)
public void nodeSourceEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeSourceEvent event)
RMEventListener.nodeSourceEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeSourceEvent)
public void nodeEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent event)
RMEventListener.nodeEvent(org.ow2.proactive.resourcemanager.common.event.RMNodeEvent)
public org.ow2.proactive.resourcemanager.common.event.dto.RMStateDelta getRMStateDelta(long filter)
public org.ow2.proactive.resourcemanager.common.event.dto.RMStateFull getRMStateFull()
public Object getNodeMBeanInfo(String nodeJmxUrl, String objectName, List<String> attrs) throws IOException, InstanceNotFoundException, IntrospectionException, MalformedObjectNameException, ReflectionException, NullPointerException
nodeJmxUrl
- mbean server urlobjectName
- name of mbeanattrs
- set of mbean attributesIOException
InstanceNotFoundException
IntrospectionException
MalformedObjectNameException
ReflectionException
NullPointerException
public String getNodeMBeanHistory(String nodeJmxUrl, String objectName, List<String> attrs, String range) throws IOException, MalformedObjectNameException, IntrospectionException, InstanceNotFoundException, ReflectionException, MBeanException
public Object getNodeMBeansInfo(String nodeJmxUrl, String objectNames, List<String> attrs) throws IOException, InstanceNotFoundException, IntrospectionException, MalformedObjectNameException, ReflectionException, NullPointerException
objectNames
- mbean names (@see ObjectName format)nodeJmxUrl
- mbean server urlattrs
- set of mbean attributesIOException
InstanceNotFoundException
IntrospectionException
MalformedObjectNameException
ReflectionException
NullPointerException
public Object getNodeMBeansHistory(String nodeJmxUrl, String objectNames, List<String> attrs, String range) throws IOException, MalformedObjectNameException, IntrospectionException, InstanceNotFoundException, ReflectionException, MBeanException