|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Object
|
+--com.adventnet.adaptors.clients.AbstractClient
|
+--com.adventnet.adaptors.clients.http.HttpClient
This class acts as the client side api for Http connector.
| Inner Class Summary | |
(package private) class |
HttpClient.MyThread
|
(package private) class |
HttpClient.NotificationReceiver
|
| Inner classes inherited from class com.adventnet.adaptors.clients.AbstractClient |
AbstractClient.HeartBeatDiagnoser |
| Field Summary | |
(package private) java.lang.Object |
adaptorInfo
|
(package private) java.net.URLConnection |
connection
|
(package private) boolean |
connectMode
|
(package private) boolean |
enableNotif
|
(package private) int |
hbinterval
|
(package private) java.util.Hashtable |
hbTable
|
(package private) boolean |
heartBeat
|
(package private) java.lang.String |
host
|
(package private) java.io.InputStream |
istream
|
(package private) java.lang.String |
keyMgrAlg
|
(package private) java.lang.String |
keyStore
|
(package private) java.lang.String |
keyStorePassword
|
(package private) java.lang.String |
keyStoreType
|
java.lang.String |
mbeanServerID
|
(package private) java.lang.Thread |
mythread
|
(package private) java.io.OutputStream |
ostream
|
(package private) int |
port
|
(package private) java.net.ServerSocket |
server
|
(package private) boolean |
sslSupport
|
(package private) java.lang.Thread |
th
|
(package private) boolean |
toBeStopped
|
(package private) java.lang.String |
trustMgrAlg
|
(package private) java.lang.String |
trustStore
|
(package private) java.lang.String |
trustStorePassword
|
(package private) java.lang.String |
trustStoreType
|
| Fields inherited from class com.adventnet.adaptors.clients.AbstractClient |
adaptorInfo,
clientProp,
heartBeatDiagnoser,
heartBeatEnabled,
heartBeatRate,
host,
isSubAgentAlive,
listeners,
port |
| Constructor Summary | |
HttpClient()
Primary constructor HttpClient. |
|
| Method Summary | |
void |
addHeartBeatListener(HeartBeatListener listener)
Add the heart beat listener to this connector client |
void |
addNotificationListener(ObjectName name,
NotificationListener listener,
NotificationFilter filter,
java.lang.Object handback)
Enables a couple (listener,handback) for a registered MBean to be added using this client through the relevant adaptor. |
void |
addNotificationListener(ObjectName name,
ObjectName listener,
NotificationFilter filter,
java.lang.Object handback)
Enables a couple (listener,handback) for a registered MBean to be added using this client through the relevant adaptor. |
void |
authenticate(com.adventnet.agent.security.UserContext userContext)
Authenticates the client to connect to the server. |
void |
connect(java.lang.String host,
int port,
java.lang.Object adaptorInfo)
Initializes the communication |
ObjectInstance |
createMBean(java.lang.String className,
ObjectName name)
Instantiates and registers a MBean with the MBeanServer using this client through the relevant adaptor. |
ObjectInstance |
createMBean(java.lang.String className,
ObjectName name,
java.lang.Object[] params,
java.lang.String[] signature)
Instantiates and registers a MBean with the MBeanServer using this client through the relevant adaptor.The MBean server will use the DefaultLoaderRepository to load the class of the MBean. |
ObjectInstance |
createMBean(java.lang.String className,
ObjectName name,
ObjectName loaderName)
Instantiates and registers a MBean with the MBeanServer using this client through the relevant adaptor. |
ObjectInstance |
createMBean(java.lang.String className,
ObjectName name,
ObjectName loaderName,
java.lang.Object[] params,
java.lang.String[] signature)
Instantiates and registers a MBean with the MBeanServer using this client through the relevant adaptor.The class loader to be used is identified by its object name. |
java.io.ObjectInputStream |
deserialize(ObjectName objectName,
byte[] data)
De-serializes a byte array in the context of the class loader of an MBean. |
java.io.ObjectInputStream |
deserialize(java.lang.String className,
byte[] data)
De-serializes a byte array in the context of a given MBean class loader. |
java.io.ObjectInputStream |
deserialize(java.lang.String className,
ObjectName objectName,
byte[] data)
De-serializes a byte array in the context of a given MBean class loader. |
void |
disconnect()
Diconnects the communication with the adaptor. |
void |
enableHeartBeat(boolean flag)
Enables the heart beat mechanism for this connector client. |
ObjectName |
getAdaptorObjectName()
Gets the ObjectName of the adaptor to which the client got connected. |
java.lang.String |
getAdaptorVersion()
Gets the version of the adaptor to which the client got connected. |
java.lang.Object |
getAttribute(ObjectName name,
java.lang.String attribute)
Gets the value of a specific attribute of a named MBean using this client through the relevant adaptor. |
AttributeList |
getAttributes(ObjectName name,
java.lang.String[] attributes)
Gets the values of several attributes of a named MBean using this client through the relevant adaptor. |
java.lang.String |
getDefaultDomain()
Returns the default domain used for naming the MBean. |
int |
getHeartBeatRate()
Gets the heart beat rate time interval(in msec) at the connector client. |
java.lang.Integer |
getMBeanCount()
Returns the number of MBeans controlled by the MBeanServer using this client through the relevant adaptor. |
MBeanInfo |
getMBeanInfo(ObjectName name)
This method discovers the attributes and operations that an MBean exposes for management using this client through the relevant adaptor.When flatten is false, inherited attributes are not returned. |
java.lang.String |
getMBeanServerID()
Gets the MBeanServerID . |
boolean |
getNotificationEnabled()
Specifies whether the notification receiver of the HttpClient is Enabled/Disabled. |
int |
getNotificationReceiverPort()
Returns the notification receiver (server) port number at which this client listens for notifications. |
ObjectInstance |
getObjectInstance(ObjectName name)
Gets the ObjectInstance for a given MBean registered with the MBean server using this client through the relevant adaptor. |
java.lang.Object |
instantiate(java.lang.String className)
Instantiates an object using the class loaders registered in the MBean server (Default Loader Repository using this client through the relevant adaptor. |
java.lang.Object |
instantiate(java.lang.String className,
java.lang.Object[] params,
java.lang.String[] signature)
Instantiates an object using the list of all class loaders registered in the MBean server (Default Loader Repository) using this client through the relevant adaptor.The object's class should have a public constructor. |
java.lang.Object |
instantiate(java.lang.String className,
ObjectName loaderName)
Instantiates an object using the class Loader specified by its ObjectName using this client through the relevant adaptor. |
java.lang.Object |
instantiate(java.lang.String className,
ObjectName loaderName,
java.lang.Object[] params,
java.lang.String[] signature)
Instantiates an object using this client through the relevant adaptor. |
java.lang.Object |
invoke(ObjectName name,
java.lang.String actionName,
java.lang.Object[] params,
java.lang.String[] signature)
Invokes an action on an MBean using this client through the relevant adaptor. |
boolean |
isAuthenticationEnabled()
Dummy implementation to check if Authentication is enabled will return false, subclasses can override to provide their own implementations |
java.lang.Boolean |
isConnectedWithAdaptor()
Indicates whether the HTTP client is connected with the HTTP adaptor. |
boolean |
isHeartBeatEnabled()
Specifies whether the heart beat mechanism is enabled for this connector client |
boolean |
isInstanceOf(ObjectName name,
java.lang.String className)
Returns true if the MBean specified is an instance of the specified class, false otherwise. |
boolean |
isRegistered(ObjectName name)
Checks whether an MBean, identified by its object name, is already registered with the MBeanServer using this client through the relevant adaptor. |
boolean |
isSSLSupportEnabled()
Indicates whether SSL Support is enabled or disabled in the HttpClient |
java.util.Set |
queryMBeans(ObjectName name,
QueryExp query)
Gets MBeans controlled by the MBeanServer using this client through the relevant adaptor. |
java.util.Set |
queryNames(ObjectName name,
QueryExp query)
Gets the names of MBeans controlled by the MBeanServer using this client through the relevant adaptor. |
ObjectInstance |
registerAsModelMBean(java.lang.Object mbean,
java.lang.String xmlFile,
ObjectName name)
Remote method call which registers the MBean. |
ObjectInstance |
registerMBean(java.lang.Object className,
ObjectName name)
Registers a pre-existing object as an MBean with the MBeanServer using this client through the relevant adaptor. |
void |
removeHeartBeatListener(HeartBeatListener listener)
Remove a heart beat listener from this connector client |
void |
removeNotificationListener(ObjectName name,
NotificationListener listener)
Enables a listener for an MBean to be removed using this client through the relevant adaptor. |
void |
removeNotificationListener(ObjectName name,
ObjectName listener)
Enables a listener for an MBean to be removed using this client through the relevant adaptor. |
void |
sendHeartBeatEvent()
This abstract method is the Heart Beat Event Generator |
void |
setAttribute(ObjectName name,
Attribute attribute)
Sets the value of a specific attribute of a named MBean using this client through the relevant adaptor. |
AttributeList |
setAttributes(ObjectName name,
AttributeList attributes)
Sets the values of several attributes of a named MBean using this client through the relevant adaptor. |
void |
setHeartBeatRate(int rate)
Sets the heart beat rate time interval(in msec) at the connector client. |
void |
setKeyMgrAlg(java.lang.String keymgralg)
Sets the value for the keymanager algorithm. |
void |
setKeyStore(java.lang.String keystr)
Sets the value for the name of the keystore. |
void |
setKeyStorePassword(java.lang.String keystrpwd)
Sets the value for the keyStorePassword. |
void |
setKeyStoreType(java.lang.String keystrtype)
Sets the value for the keyStoreType. |
void |
setNotificationEnabled(boolean enableNotif)
Enables/Disables the notification receiver of the HttpClient. |
void |
setNotificationReceiverPort(int port)
Sets the notification receiver (server) port number at which this client listens for notifications. |
void |
setSSLSupportEnabled(boolean sslSupport)
Enables/Disables the SSL Support of the HttpClient. |
void |
setTrustMgrAlg(java.lang.String trustmgralg)
Sets the value for the trustmanager algorithm. |
void |
setTrustStore(java.lang.String truststr)
Sets the value for the name of the trustStore. |
void |
setTrustStorePassword(java.lang.String truststrpwd)
Sets the value for the truststore password. |
void |
setTrustStoreType(java.lang.String truststrtype)
Sets the value for the truststore type. |
void |
unregisterMBean(ObjectName name)
De-registers an MBean from the MBeanServer using this client through the relevant adaptor. |
| Methods inherited from class com.adventnet.adaptors.clients.AbstractClient |
asyncGetAttribute,
asyncGetAttributes,
asyncInvoke,
asyncSetAttributes,
setProperty,
startHeartBeat,
stopHeartBeat |
| Methods inherited from class java.lang.Object |
|
| Field Detail |
java.lang.String host
int port
java.lang.Object adaptorInfo
java.net.URLConnection connection
java.io.InputStream istream
java.io.OutputStream ostream
boolean sslSupport
java.lang.String keyStore
java.lang.String keyStoreType
java.lang.String keyStorePassword
java.lang.String trustStore
java.lang.String trustStoreType
java.lang.String trustStorePassword
java.lang.String keyMgrAlg
java.lang.String trustMgrAlg
public java.lang.String mbeanServerID
boolean enableNotif
java.lang.Thread th
boolean connectMode
java.net.ServerSocket server
boolean heartBeat
int hbinterval
java.lang.Thread mythread
boolean toBeStopped
java.util.Hashtable hbTable
| Constructor Detail |
public HttpClient()
| Method Detail |
public void setSSLSupportEnabled(boolean sslSupport)
enableNotif - If true Enables SSL support in the HttpClient and
if False Disables SSL support in the HttpClient.public boolean isSSLSupportEnabled()
public int getNotificationReceiverPort()
setNotificationReceiverPortpublic void setNotificationReceiverPort(int port)
port - the notification receiver (server) port number at which
this client listens for notifications.getNotificationReceiverPortpublic void setNotificationEnabled(boolean enableNotif)
enableNotif - If true Enables the notification receiver of the HttpClient and
if False Disables the notification receiver of the HttpClient.getNotificationEnabledpublic boolean getNotificationEnabled()
setNotificationEnabledpublic void setKeyStore(java.lang.String keystr)
keystr - name of the keystore.public void setKeyStoreType(java.lang.String keystrtype)
keystrtype - value for the keystore type.public void setKeyStorePassword(java.lang.String keystrpwd)
keystrpwd - value for the keystore password.public void setTrustStore(java.lang.String truststr)
truststr - name of the trustStore.public void setTrustStoreType(java.lang.String truststrtype)
truststrtype - value for the truststore type.public void setTrustStorePassword(java.lang.String truststrpwd)
truststrpwd - value for the truststore password.public void setKeyMgrAlg(java.lang.String keymgralg)
keymgralg - value for the keymanager algorithm.public void setTrustMgrAlg(java.lang.String trustmgralg)
trustmgralg - value for the trustmanager algorithm.
public void connect(java.lang.String host,
int port,
java.lang.Object adaptorInfo)
throws java.net.ConnectException
host - The host name of the adaptor.port - The port number of the adaptor.adaptorInfo - The information object specific to the adaptor.
public java.io.ObjectInputStream deserialize(ObjectName objectName,
byte[] data)
throws InstanceNotFoundException,
OperationsException
De-serializes a byte array in the context of the class loader of an MBean.
name - The name of the MBean whose class loader should be
used for the de-serialization.data - The byte array to be de-sererialized.
public java.io.ObjectInputStream deserialize(java.lang.String className,
byte[] data)
throws OperationsException,
ReflectionException
De-serializes a byte array in the context of a given MBean
class loader. The class loader is found by loading the class
className through the Class Loader
Repository. The resultant class's class loader is the one to
use.
className - The name of the class whose class loader should be
used for the de-serialization.data - The byte array to be de-sererialized.
public java.io.ObjectInputStream deserialize(java.lang.String className,
ObjectName objectName,
byte[] data)
throws InstanceNotFoundException,
OperationsException,
ReflectionException
De-serializes a byte array in the context of a given MBean class loader. The class loader is the one that loaded the class with name "className". The name of the class loader to be used for loading the specified class is specified. If null, the MBean Server's class loader will be used.
className - The name of the class whose class loader should be
used for the de-serialization.data - The byte array to be de-sererialized.loaderName - The name of the class loader to be used for
loading the specified class. If null, the MBean Server's class
loader will be used.
public void authenticate(com.adventnet.agent.security.UserContext userContext)
throws com.adventnet.agent.security.AuthenticationException
UserContext - public boolean isAuthenticationEnabled()
public java.util.Set queryMBeans(ObjectName name,
QueryExp query)
name - The object name pattern identifying the MBeans to be
retrieved. If null orempty all the MBeans registered will be retrieved.query - The query expression to be applied for selecting MBeans.public void disconnect()
public java.lang.String getAdaptorVersion()
throws java.lang.Exception
public ObjectName getAdaptorObjectName()
throws java.lang.Exception
public java.lang.Boolean isConnectedWithAdaptor()
throws java.net.NoRouteToHostException
public void enableHeartBeat(boolean flag)
boolean - public int getHeartBeatRate()
public void setHeartBeatRate(int rate)
rate - The heart beat rate time interval(in msec) at the connector client.public void sendHeartBeatEvent()
public boolean isHeartBeatEnabled()
public void addHeartBeatListener(HeartBeatListener listener)
listener - The Listener Object which will handles the HeartBeat.removeHeartBeatListenerpublic void removeHeartBeatListener(HeartBeatListener listener)
listener - The Listener Object which will handles the HeartBeat.addHeartBeatListener
public void addNotificationListener(ObjectName name,
NotificationListener listener,
NotificationFilter filter,
java.lang.Object handback)
throws InstanceNotFoundException
name - The name of the MBean on which the listener should be added.listener - The listener object which will handles notifications
emitted by the registered MBean.filter - The filter object. If not specified, no filtering will be
performed before handling notifications.handback - The context to be sent to the listener when a notification
is emitted.
public void addNotificationListener(ObjectName name,
ObjectName listener,
NotificationFilter filter,
java.lang.Object handback)
throws InstanceNotFoundException
name - The name of the MBean on which the listener should be added.listener - The listener name which will handles notifications
emitted by the registered MBean.filter - The filter object. If not specified, no filtering will be
performed before handling notifications.handback - The context to be sent to the listener when a notification
is emitted.
public ObjectInstance createMBean(java.lang.String className,
ObjectName name)
throws ReflectionException,
InstanceAlreadyExistsException,
MBeanRegistrationException,
MBeanException,
NotCompliantMBeanException,
RuntimeOperationsException
className - The class name of the MBean to be instantiated.name - The object name of the MBean. May be null.
public ObjectInstance createMBean(java.lang.String className,
ObjectName name,
java.lang.Object[] params,
java.lang.String[] signature)
throws ReflectionException,
InstanceAlreadyExistsException,
MBeanRegistrationException,
MBeanException,
NotCompliantMBeanException,
RuntimeOperationsException
className - The class name of the MBean to be instantiated.name - The object name of the MBean. May be null.params - An array containing the parameters of the constructor to be
invoked.signature - An array containing the signature of the constructor to be
invoked.
public ObjectInstance createMBean(java.lang.String className,
ObjectName name,
ObjectName loaderName)
throws ReflectionException,
InstanceAlreadyExistsException,
MBeanRegistrationException,
MBeanException,
NotCompliantMBeanException,
InstanceNotFoundException,
RuntimeOperationsException
className - The class name of the MBean to be instantiated.name - The object name of the MBean. May be null.loaderName - The object name of the class loader to be used.
public ObjectInstance createMBean(java.lang.String className,
ObjectName name,
ObjectName loaderName,
java.lang.Object[] params,
java.lang.String[] signature)
throws ReflectionException,
InstanceAlreadyExistsException,
MBeanRegistrationException,
MBeanException,
NotCompliantMBeanException,
InstanceNotFoundException,
RuntimeOperationsException
className - The class name of the MBean to be instantiated.name - The object name of the MBean. May be null.params - An array containing the parameters of the constructor to be
invoked.signature - An array containing the signature of the constructor to be
invoked.loaderName - The object name of the class loader to be used.
public java.lang.Object getAttribute(ObjectName name,
java.lang.String attribute)
throws MBeanException,
AttributeNotFoundException,
InstanceNotFoundException,
ReflectionException
name - The object name of the MBean from which the
attribute is to be retrieved.attribute - A String specifying the name of the
attribute to be retrieved.getAttributes
public AttributeList getAttributes(ObjectName name,
java.lang.String[] attributes)
throws InstanceNotFoundException,
ReflectionException
name - The object name of the MBean from which the
attributes are to be retrieved.attributes - A list of the attributes to be retrieved.getAttributepublic java.lang.String getDefaultDomain()
public java.lang.Integer getMBeanCount()
public MBeanInfo getMBeanInfo(ObjectName name)
throws InstanceNotFoundException,
IntrospectionException,
ReflectionException
name - The name of the MBean to analyze
public ObjectInstance getObjectInstance(ObjectName name)
throws InstanceNotFoundException
name - The object name of the MBean.
public java.lang.Object instantiate(java.lang.String className)
throws ReflectionException,
MBeanException
className - The class name of the object to be instantiated.
public java.lang.Object instantiate(java.lang.String className,
java.lang.Object[] params,
java.lang.String[] signature)
throws ReflectionException,
MBeanException
className - The class name of the object to be instantiated.params - An array containing the parameters of the constructor to be invoked.signature - An array containing the signature of the constructor to be invoked.
public java.lang.Object instantiate(java.lang.String className,
ObjectName loaderName)
throws ReflectionException,
MBeanException,
InstanceNotFoundException
className - The class name of the object to be instantiated.loaderName - The object name of the class loader to be used.
public java.lang.Object instantiate(java.lang.String className,
ObjectName loaderName,
java.lang.Object[] params,
java.lang.String[] signature)
throws ReflectionException,
MBeanException,
InstanceNotFoundException
className - The class name of the object to be instantiated.loaderName - The object name of the class loader to be used.params - An array containing the parameters of the constructor to be invoked.signature - An array containing the signature of the constructor to be invoked.
public java.lang.Object invoke(ObjectName name,
java.lang.String actionName,
java.lang.Object[] params,
java.lang.String[] signature)
throws InstanceNotFoundException,
MBeanException,
ReflectionException
name - The object name of the MBean on which
the method is to be invoked.actionName - The name of the action to be invoked.params - An array containing the parameters to be
set when the action is invokedsignature - An array containing the signature of
the action. The class objects will be loaded using the
same class loader as the one used for loading the MBean
on which the action was invoked.public boolean isRegistered(ObjectName name)
name - The object name of the MBean to be checked.
public boolean isInstanceOf(ObjectName name,
java.lang.String className)
throws InstanceNotFoundException
name - The object name of the MBean to be checked.className - The name of the class.
public java.util.Set queryNames(ObjectName name,
QueryExp query)
name - The object name pattern identifying the MBean names
to be retrieved. If null or empty, the name of all registered
MBeans will be retrieved.query - The query expression to be applied for selecting MBeans.
public ObjectInstance registerMBean(java.lang.Object className,
ObjectName name)
throws InstanceAlreadyExistsException,
MBeanRegistrationException,
NotCompliantMBeanException,
RuntimeOperationsException
String - The classname of the Java Bean to be registered as an MBean.name - The object name of the MBean. May be null.
public ObjectInstance registerAsModelMBean(java.lang.Object mbean,
java.lang.String xmlFile,
ObjectName name)
throws InstanceAlreadyExistsException,
MBeanRegistrationException,
NotCompliantMBeanException
mbean - The mbean object which is to be instantiated locally as modelmbean in the mbean
server and registered.xmlFile - The path of the xml file name locally in the mbean server.name - The object name of the MBean. May be null.
public void removeNotificationListener(ObjectName name,
NotificationListener listener)
throws InstanceNotFoundException,
ListenerNotFoundException
name - The name of the MBean on which the listener should be removedlistener - The listener object which will handles notifications
emitted by the registered MBean.This method will remove all information
related to this listener.addNotificationListener
public void removeNotificationListener(ObjectName name,
ObjectName listener)
throws InstanceNotFoundException,
ListenerNotFoundException
name - The name of the MBean on which the listener should be removedlistener - The listener name which will handles notifications
emitted by the registered MBean. This method will remove all information
related to this listener.addNotificationListener.
public void setAttribute(ObjectName name,
Attribute attribute)
throws InstanceNotFoundException,
AttributeNotFoundException,
InvalidAttributeValueException,
MBeanException,
ReflectionException
name - The name of the MBean within which the
attribute is to be set.attribute - The identification of the attribute to
be set and the value it is to be set to.
public AttributeList setAttributes(ObjectName name,
AttributeList attributes)
throws InstanceNotFoundException,
ReflectionException
name - The object name of the MBean within which the
attributes are to be set.attributes - A list of attributes: The identification
of the attributes to be set and the values they are to be set to.
public void unregisterMBean(ObjectName name)
throws InstanceNotFoundException,
MBeanRegistrationException
name - The object name of the MBean to be de-registered.registerMBeanpublic java.lang.String getMBeanServerID()
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||