ConnectionImpl (Rhino 2.5 Remote API)

java.lang.Object
- com.opencloud.slee.remote.ConnectionImpl

All Implemented Interfaces:

RhinoConnection, MBeanServerConnection
```
public class ConnectionImpl
extends Object
implements RhinoConnection, MBeanServerConnection
```
Implementation class for connections to Rhino. Use the RhinoConnectionFactory to obtain instances of this class.

Author:

OpenCloud

Constructor Summary

Constructors
Modifier	Constructor and Description
`protected`	`ConnectionImpl(String[] hosts, String username, String password)`
`protected`	`ConnectionImpl(String[] hosts, String username, String password, boolean attemptRhinoSsl)`

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`addNotificationListener(ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback)`
`void`	`addNotificationListener(ObjectName name, ObjectName listener, NotificationFilter filter, Object handback)`
`void`	`connect()` Try to connect this connection.
`ObjectInstance`	`createMBean(String className, ObjectName name)`
`ObjectInstance`	`createMBean(String className, ObjectName name, Object[] params, String[] signature)`
`ObjectInstance`	`createMBean(String className, ObjectName name, ObjectName loaderName)`
`ObjectInstance`	`createMBean(String className, ObjectName name, ObjectName loaderName, Object[] params, String[] signature)`
`protected void`	`createMBeanServerConnection(String host, int port, String username, String password)`
`void`	`disconnect()` Disconnect this connection.
`Object`	`getAttribute(ObjectName name, String attribute)`
`AttributeList`	`getAttributes(ObjectName name, String[] attributes)`
`boolean`	`getConnectedState()` Whether or not this connection is connected.
`String`	`getDefaultDomain()`
`String[]`	`getDomains()`
`JMXConnector`	`getJmxConnector()` Get the JMXConnector associated with this MBeanServer connection.
`Integer`	`getMBeanCount()`
`MBeanInfo`	`getMBeanInfo(ObjectName name)`
`ObjectInstance`	`getObjectInstance(ObjectName name)`
`String`	`getServerHost()` The host name of the current connection.
`int`	`getServerNodeId()` The node ID of the server the current connection is to.
`int`	`getServerPort()` The port of the current connection.
`RhinoVersion`	`getServerRhinoVersion()` The version of Rhino this connection is to.
`Object`	`invoke(ObjectName name, String operationName, Object[] params, String[] signature)`
`boolean`	`isInstanceOf(ObjectName name, String className)`
`boolean`	`isRegistered(ObjectName name)`
`Set`	`queryMBeans(ObjectName name, QueryExp query)`
`Set`	`queryNames(ObjectName name, QueryExp query)`
`void`	`reconnect()` Disconnect then connect this connection.
`void`	`removeNotificationListener(ObjectName name, NotificationListener listener)`
`void`	`removeNotificationListener(ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback)`
`void`	`removeNotificationListener(ObjectName name, ObjectName listener)`
`void`	`removeNotificationListener(ObjectName name, ObjectName listener, NotificationFilter filter, Object handback)`
`void`	`setAllowedExecutionContext(ExecutionContext ctx)` Tell this connection to only allow particular connection contexts.
`void`	`setAttribute(ObjectName name, Attribute attribute)`
`AttributeList`	`setAttributes(ObjectName name, AttributeList attributes)`
`void`	`setNamespace(String namespace)` Set the current Rhino namespace associated with this connection.
`void`	`testConnection()` Test this connection by invoking a basic MBean operation.
`String`	`toString()`
`void`	`unregisterMBean(ObjectName name)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ConnectionImpl

protected ConnectionImpl(String[] hosts,
              String username,
              String password)
                  throws ConnectionException

Throws:: ConnectionException

ConnectionImpl

protected ConnectionImpl(String[] hosts,
              String username,
              String password,
              boolean attemptRhinoSsl)
                  throws ConnectionException

Throws:: ConnectionException

Method Detail

setNamespace
```
public void setNamespace(String namespace)
```
Description copied from interface: RhinoConnection

Set the current Rhino namespace associated with this connection. This namespace will be set as the active namespace if/when the connection needs to be re-established. Note that this method only affects local state, it does *not* invoke the NamespaceManagementMBean in Rhino to set the current active namespace.

Specified by:

setNamespace in interface RhinoConnection

Parameters:
namespace - the namespace. May be null to indicate the default namespace.

connect
```
public void connect()
             throws ConnectionException
```
Description copied from interface: RhinoConnection

Try to connect this connection.

Specified by:

connect in interface RhinoConnection

Throws:

ConnectionException - if the connection attempt failed

disconnect
```
public void disconnect()
```
Description copied from interface: RhinoConnection

Disconnect this connection.

Specified by:

disconnect in interface RhinoConnection

testConnection
```
public void testConnection()
                    throws ConnectionException
```
Description copied from interface: RhinoConnection

Test this connection by invoking a basic MBean operation. If the test fails, an reconnect attempt will be triggered automatically.

Specified by:

testConnection in interface RhinoConnection

Throws:

ConnectionException - if the test failed and the attempt to automatically reconnect failed.

reconnect
```
public void reconnect()
               throws ConnectionException
```
Description copied from interface: RhinoConnection

Disconnect then connect this connection.

Specified by:

reconnect in interface RhinoConnection

Throws:

ConnectionException - if the connection attempt failed

getJmxConnector
```
public JMXConnector getJmxConnector()
```
Description copied from interface: RhinoConnection

Get the JMXConnector associated with this MBeanServer connection.

Specified by:

getJmxConnector in interface RhinoConnection

Returns:
a JMXConnector instance

getConnectedState
```
public boolean getConnectedState()
```
Description copied from interface: RhinoConnection

Whether or not this connection is connected.

Specified by:

getConnectedState in interface RhinoConnection

Returns:
state of the connection

getServerHost
```
public String getServerHost()
```
Description copied from interface: RhinoConnection

The host name of the current connection. Useful if this connection is configured to try multiple hosts.

Specified by:

getServerHost in interface RhinoConnection

Returns:
host where this connection object is currently connected to Rhino

getServerPort
```
public int getServerPort()
```
Description copied from interface: RhinoConnection

The port of the current connection. Useful if this connection is configured to try multiple hosts.

Specified by:

getServerPort in interface RhinoConnection

Returns:
port where this connection object is currently connected to Rhino

getServerNodeId
```
public int getServerNodeId()
```
Description copied from interface: RhinoConnection

The node ID of the server the current connection is to. Useful if this connection is configured to try multiple hosts.

Specified by:

getServerNodeId in interface RhinoConnection

Returns:
node id of Rhino where this connection object is currently connected to

getServerRhinoVersion
```
public RhinoVersion getServerRhinoVersion()
```
Description copied from interface: RhinoConnection

The version of Rhino this connection is to. Only available for Rhino versions 2.2 and above. This method returns null for versions of Rhino prior to 2.2.

Specified by:

getServerRhinoVersion in interface RhinoConnection

Returns:
Rhino version

setAllowedExecutionContext
```
public void setAllowedExecutionContext(ExecutionContext ctx)
```
Description copied from interface: RhinoConnection

Tell this connection to only allow particular connection contexts. See ExecutionContext for more details.

Specified by:

setAllowedExecutionContext in interface RhinoConnection

Parameters:
ctx - the context to allow

createMBeanServerConnection

protected void createMBeanServerConnection(String host,
                               int port,
                               String username,
                               String password)
                                    throws ConnectionException,
                                           IOException

Throws:: ConnectionException; IOException

toString
```
public String toString()
```
Overrides:

toString in class Object

createMBean

public ObjectInstance createMBean(String className,
                         ObjectName name)
                           throws IOException,
                                  ReflectionException,
                                  InstanceAlreadyExistsException,
                                  MBeanException,
                                  NotCompliantMBeanException

Specified by:: createMBean in interface MBeanServerConnection
Throws:: IOException; ReflectionException; InstanceAlreadyExistsException; MBeanException; NotCompliantMBeanException

createMBean

public ObjectInstance createMBean(String className,
                         ObjectName name,
                         ObjectName loaderName)
                           throws IOException,
                                  ReflectionException,
                                  InstanceAlreadyExistsException,
                                  MBeanException,
                                  NotCompliantMBeanException,
                                  InstanceNotFoundException

Specified by:: createMBean in interface MBeanServerConnection
Throws:: IOException; ReflectionException; InstanceAlreadyExistsException; MBeanException; NotCompliantMBeanException; InstanceNotFoundException

createMBean

public ObjectInstance createMBean(String className,
                         ObjectName name,
                         Object[] params,
                         String[] signature)
                           throws IOException,
                                  ReflectionException,
                                  InstanceAlreadyExistsException,
                                  MBeanException,
                                  NotCompliantMBeanException

Specified by:: createMBean in interface MBeanServerConnection
Throws:: IOException; ReflectionException; InstanceAlreadyExistsException; MBeanException; NotCompliantMBeanException

createMBean

public ObjectInstance createMBean(String className,
                         ObjectName name,
                         ObjectName loaderName,
                         Object[] params,
                         String[] signature)
                           throws IOException,
                                  ReflectionException,
                                  InstanceAlreadyExistsException,
                                  MBeanException,
                                  NotCompliantMBeanException,
                                  InstanceNotFoundException

Specified by:: createMBean in interface MBeanServerConnection
Throws:: IOException; ReflectionException; InstanceAlreadyExistsException; MBeanException; NotCompliantMBeanException; InstanceNotFoundException

unregisterMBean

public void unregisterMBean(ObjectName name)
                     throws IOException,
                            InstanceNotFoundException,
                            MBeanRegistrationException

Specified by:: unregisterMBean in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; MBeanRegistrationException

getObjectInstance

public ObjectInstance getObjectInstance(ObjectName name)
                                 throws IOException,
                                        InstanceNotFoundException

Specified by:: getObjectInstance in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException

queryMBeans

public Set queryMBeans(ObjectName name,
              QueryExp query)
                throws IOException

Specified by:: queryMBeans in interface MBeanServerConnection
Throws:: IOException

queryNames

public Set queryNames(ObjectName name,
             QueryExp query)
               throws IOException

Specified by:: queryNames in interface MBeanServerConnection
Throws:: IOException

isRegistered

public boolean isRegistered(ObjectName name)
                     throws IOException

Specified by:: isRegistered in interface MBeanServerConnection
Throws:: IOException

getMBeanCount
```
public Integer getMBeanCount()
                      throws IOException
```
Specified by:

getMBeanCount in interface MBeanServerConnection

Throws:

IOException

getAttribute

public Object getAttribute(ObjectName name,
                  String attribute)
                    throws IOException,
                           MBeanException,
                           AttributeNotFoundException,
                           InstanceNotFoundException,
                           ReflectionException

Specified by:: getAttribute in interface MBeanServerConnection
Throws:: IOException; MBeanException; AttributeNotFoundException; InstanceNotFoundException; ReflectionException

getAttributes

public AttributeList getAttributes(ObjectName name,
                          String[] attributes)
                            throws IOException,
                                   InstanceNotFoundException,
                                   ReflectionException

Specified by:: getAttributes in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; ReflectionException

setAttribute

public void setAttribute(ObjectName name,
                Attribute attribute)
                  throws IOException,
                         InstanceNotFoundException,
                         AttributeNotFoundException,
                         InvalidAttributeValueException,
                         MBeanException,
                         ReflectionException

Specified by:: setAttribute in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; AttributeNotFoundException; InvalidAttributeValueException; MBeanException; ReflectionException

setAttributes

public AttributeList setAttributes(ObjectName name,
                          AttributeList attributes)
                            throws IOException,
                                   InstanceNotFoundException,
                                   ReflectionException

Specified by:: setAttributes in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; ReflectionException

invoke

public Object invoke(ObjectName name,
            String operationName,
            Object[] params,
            String[] signature)
              throws IOException,
                     InstanceNotFoundException,
                     MBeanException,
                     ReflectionException

Specified by:: invoke in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; MBeanException; ReflectionException

getDefaultDomain
```
public String getDefaultDomain()
                        throws IOException
```
Specified by:

getDefaultDomain in interface MBeanServerConnection

Throws:

IOException

getDomains
```
public String[] getDomains()
                    throws IOException
```
Specified by:

getDomains in interface MBeanServerConnection

Throws:

IOException

addNotificationListener

public void addNotificationListener(ObjectName name,
                           NotificationListener listener,
                           NotificationFilter filter,
                           Object handback)
                             throws IOException,
                                    InstanceNotFoundException

Specified by:: addNotificationListener in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException

addNotificationListener

public void addNotificationListener(ObjectName name,
                           ObjectName listener,
                           NotificationFilter filter,
                           Object handback)
                             throws IOException,
                                    InstanceNotFoundException

Specified by:: addNotificationListener in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException

removeNotificationListener

public void removeNotificationListener(ObjectName name,
                              NotificationListener listener)
                                throws IOException,
                                       InstanceNotFoundException,
                                       ListenerNotFoundException

Specified by:: removeNotificationListener in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; ListenerNotFoundException

removeNotificationListener

public void removeNotificationListener(ObjectName name,
                              ObjectName listener)
                                throws IOException,
                                       InstanceNotFoundException,
                                       ListenerNotFoundException

Specified by:: removeNotificationListener in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; ListenerNotFoundException

removeNotificationListener

public void removeNotificationListener(ObjectName name,
                              ObjectName listener,
                              NotificationFilter filter,
                              Object handback)
                                throws IOException,
                                       InstanceNotFoundException,
                                       ListenerNotFoundException

Specified by:: removeNotificationListener in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; ListenerNotFoundException

removeNotificationListener

public void removeNotificationListener(ObjectName name,
                              NotificationListener listener,
                              NotificationFilter filter,
                              Object handback)
                                throws IOException,
                                       InstanceNotFoundException,
                                       ListenerNotFoundException

Specified by:: removeNotificationListener in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; ListenerNotFoundException

getMBeanInfo

public MBeanInfo getMBeanInfo(ObjectName name)
                       throws IOException,
                              InstanceNotFoundException,
                              IntrospectionException,
                              ReflectionException

Specified by:: getMBeanInfo in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException; IntrospectionException; ReflectionException

isInstanceOf

public boolean isInstanceOf(ObjectName name,
                   String className)
                     throws IOException,
                            InstanceNotFoundException

Specified by:: isInstanceOf in interface MBeanServerConnection
Throws:: IOException; InstanceNotFoundException

Class ConnectionImpl

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

ConnectionImpl

ConnectionImpl

Method Detail

setNamespace

connect

disconnect

testConnection

reconnect

getJmxConnector

getConnectedState

getServerHost

getServerPort

getServerNodeId

getServerRhinoVersion

setAllowedExecutionContext

createMBeanServerConnection

toString

createMBean

createMBean

createMBean

createMBean

unregisterMBean

getObjectInstance

queryMBeans

queryNames

isRegistered

getMBeanCount

getAttribute

getAttributes

setAttribute

setAttributes

invoke

getDefaultDomain

getDomains

addNotificationListener

addNotificationListener

removeNotificationListener

removeNotificationListener

removeNotificationListener

removeNotificationListener

getMBeanInfo

isInstanceOf