org.jboss.ha.jndi
Class DetachedHANamingService

java.lang.Object
  org.jboss.mx.util.JBossNotificationBroadcasterSupport
      org.jboss.system.ServiceMBeanSupport
          org.jboss.ha.jndi.DetachedHANamingService

All Implemented Interfaces:

javax.management.MBeanRegistration, javax.management.NotificationBroadcaster, javax.management.NotificationEmitter, DetachedHANamingServiceMBean, org.jboss.system.Service, org.jboss.system.ServiceMBean

Direct Known Subclasses:

HANamingService

public class DetachedHANamingService
extends org.jboss.system.ServiceMBeanSupport
implements DetachedHANamingServiceMBean

Management Bean for the protocol independent HA-JNDI service. This allows the naming service transport layer to be provided by a detached invoker service like JRMPInvokerHA + ProxyFactoryHA.

Version:

$Revision: 1.2.4.15 $

Author:

Bill Burke, Sacha Labourey, Scott.Stark@jboss.org

Field Summary

protected String	adGroupAddress The autodiscovery multicast group
protected int	adGroupPort The autodiscovery port
protected org.jboss.ha.jndi.DetachedHANamingService.AutomaticDiscovery	autoDiscovery The runable task for discovery request packets
protected int	autoDiscoveryTTL The autodiscovery Multicast reply TTL
protected int	backlog The bootstrapSocket listen queue depth
protected InetAddress	bindAddress The interface to bind to.
protected ServerSocket	bootstrapSocket The jnp server socket through which the HAJNDI stub is vended
protected ClusterPartitionMBean	clusterPartition The ClusterPartition with which we are associated.
protected InetAddress	discoveryBindAddress The interface to bind the Multicast socket for autodiscovery to
protected boolean	discoveryDisabled A flag indicating if autodiscovery should be disabled
protected ServerSocketFactory	jnpServerSocketFactory An optional custom server socket factory for the bootstrap lookup
protected String	jnpServerSocketFactoryName The class name of the optional custom JNP server socket factory
protected org.jboss.util.threadpool.ThreadPool	lookupPool The thread pool used to handle jnp stub lookup requests
protected Map	marshalledInvocationMapping The mapping from the long method hash to the Naming Method
protected HAPartition	partition The HAPartition used for the state transfer service
protected String	partitionName The partition name used to lookup the HAPartition binding
protected int	port The jnp protocol listening port.
protected org.jnp.interfaces.Naming	stub The protocol stub returned to clients by the bootstrap lookup
protected HAJNDI	theServer The Naming interface server implementation

Fields inherited from class org.jboss.system.ServiceMBeanSupport

log, server, SERVICE_CONTROLLER_SIG, serviceName

Fields inherited from interface org.jboss.system.ServiceMBean

CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED

Constructor Summary

DetachedHANamingService()

Method Summary

protected void	createService()
protected void	destroyService()
protected HAPartition	findHAPartitionWithName(String name)
String	getAutoDiscoveryAddress() Get the auto-discovery bootstrap multicast address.
String	getAutoDiscoveryBindAddress() Get the auto-discovery bootstrap multicast bind address.
int	getAutoDiscoveryGroup() Get the Auto-discovery multicast port
int	getAutoDiscoveryTTL() Get the TTL (time-to-live) for autodiscovery IP multicast packets
int	getBacklog() Get the accept backlog for the bootstrap server socket
String	getBindAddress() Get the bootstrap IP address on which the HA-JNDI stub is made available
ClusterPartitionMBean	getClusterPartition() Get the underlying partition used by this service.
boolean	getDiscoveryDisabled() prevent autodiscovery service from starting
Map	getMethodMap() Expose the Naming service interface mapping as a read-only attribute
protected org.jnp.interfaces.Naming	getNamingProxy() Get the Naming proxy for the transport.
String	getPartitionName() Gets the name of the HAPartition used by this service.
int	getPort() Get the bootstrap port on which the HA-JNDI stub is made available
javax.management.ObjectName	getProxyFactoryObjectName() Get the proxy factory service name used to create the Naming transport proxy.
protected void	initBootstrapListener() Bring up the bootstrap lookup port for obtaining the naming service proxy
Object	invoke(org.jboss.invocation.Invocation invocation) Expose the Naming service via JMX to invokers.
void	setAutoDiscoveryAddress(String adAddress) Set the auto-discovery bootstrap multicast address.
void	setAutoDiscoveryBindAddress(String address) Set the auto-discovery bootstrap multicast bind address.
void	setAutoDiscoveryGroup(int adGroup) Set the Auto-discovery multicast port.
void	setAutoDiscoveryTTL(int ttl) Set the TTL (time-to-live) for autodiscovery IP multicast packets
void	setBacklog(int backlog) Set the accept backlog for the bootstrap server socket
void	setBindAddress(String host) Set the bootstrap IP address on which the HA-JNDI stub is made available
void	setClusterPartition(ClusterPartitionMBean clusterPartition) Sets the underlying partition used by this service.
void	setDiscoveryDisabled(boolean disable) prevent autodiscovery service from starting
void	setJNPServerSocketFactory(String factoryClassName)
void	setLookupPool(org.jboss.util.threadpool.BasicThreadPoolMBean poolMBean) Set the thread pool used for the bootstrap and autodiscovery lookups
void	setPartitionName(String partitionName) Sets the name of the HAPartition used by this service.
void	setPort(int p) Set the bootstrap port on which the HA-JNDI stub is made available
void	setProxyFactoryObjectName(javax.management.ObjectName proxyFactory) Set the proxy factory service name used to create the Naming transport proxy.
protected void	startService()
void	startService(HAPartition haPartition)
protected void	stopService()

Methods inherited from class org.jboss.system.ServiceMBeanSupport

create, destroy, getDeploymentInfo, getLog, getName, getNextNotificationSequenceNumber, getObjectName, getServer, getServiceName, getState, getStateString, jbossInternalCreate, jbossInternalDescription, jbossInternalDestroy, jbossInternalLifecycle, jbossInternalStart, jbossInternalStop, postDeregister, postRegister, preDeregister, preRegister, start, stop

Methods inherited from class org.jboss.mx.util.JBossNotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, nextNotificationSequenceNumber, removeNotificationListener, removeNotificationListener, sendNotification

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jboss.system.ServiceMBean

getName, getState, getStateString, jbossInternalLifecycle

Methods inherited from interface org.jboss.system.Service

create, destroy, start, stop

Field Detail

bootstrapSocket

protected ServerSocket bootstrapSocket

The jnp server socket through which the HAJNDI stub is vended

theServer

protected HAJNDI theServer

The Naming interface server implementation

marshalledInvocationMapping

protected Map marshalledInvocationMapping

The mapping from the long method hash to the Naming Method

stub

protected org.jnp.interfaces.Naming stub

The protocol stub returned to clients by the bootstrap lookup

partition

protected HAPartition partition

The HAPartition used for the state transfer service

clusterPartition

protected ClusterPartitionMBean clusterPartition

The ClusterPartition with which we are associated.

partitionName

protected String partitionName

The partition name used to lookup the HAPartition binding

bindAddress

protected InetAddress bindAddress

The interface to bind to. This is useful for multi-homed hosts that want control over which interfaces accept connections.

backlog

protected int backlog

The bootstrapSocket listen queue depth

port

protected int port

The jnp protocol listening port. The default is 1100, the same as the RMI registry default port.

adGroupAddress

protected String adGroupAddress

The autodiscovery multicast group

adGroupPort

protected int adGroupPort

The autodiscovery port

discoveryBindAddress

protected InetAddress discoveryBindAddress

The interface to bind the Multicast socket for autodiscovery to

autoDiscovery

protected org.jboss.ha.jndi.DetachedHANamingService.AutomaticDiscovery autoDiscovery

The runable task for discovery request packets

discoveryDisabled

protected boolean discoveryDisabled

A flag indicating if autodiscovery should be disabled

autoDiscoveryTTL

protected int autoDiscoveryTTL

The autodiscovery Multicast reply TTL

jnpServerSocketFactory

protected ServerSocketFactory jnpServerSocketFactory

An optional custom server socket factory for the bootstrap lookup

jnpServerSocketFactoryName

protected String jnpServerSocketFactoryName

The class name of the optional custom JNP server socket factory

lookupPool

protected org.jboss.util.threadpool.ThreadPool lookupPool

The thread pool used to handle jnp stub lookup requests

Constructor Detail

DetachedHANamingService

public DetachedHANamingService()

Method Detail

getMethodMap

public Map getMethodMap()

Expose the Naming service interface mapping as a read-only attribute

Specified by:

getMethodMap in interface DetachedHANamingServiceMBean

Returns:

A Map of the Naming interface

getClusterPartition

public ClusterPartitionMBean getClusterPartition()

Description copied from interface: DetachedHANamingServiceMBean

Get the underlying partition used by this service.

Specified by:

getClusterPartition in interface DetachedHANamingServiceMBean

Returns:

the partition

setClusterPartition

public void setClusterPartition(ClusterPartitionMBean clusterPartition)

Description copied from interface: DetachedHANamingServiceMBean

Sets the underlying partition used by this service.

Specified by:

setClusterPartition in interface DetachedHANamingServiceMBean

Parameters:

clusterPartition - the partition

getPartitionName

public String getPartitionName()

Description copied from interface: DetachedHANamingServiceMBean

Gets the name of the HAPartition used by this service.

Specified by:

getPartitionName in interface DetachedHANamingServiceMBean

Returns:

the name of the partition

setPartitionName

public void setPartitionName(String partitionName)

Description copied from interface: DetachedHANamingServiceMBean

Sets the name of the HAPartition used by this service.

Specified by:

setPartitionName in interface DetachedHANamingServiceMBean

Parameters:

partitionName - the name of the partition

getProxyFactoryObjectName

public javax.management.ObjectName getProxyFactoryObjectName()

Description copied from interface: DetachedHANamingServiceMBean

Get the proxy factory service name used to create the Naming transport proxy.

Specified by:

getProxyFactoryObjectName in interface DetachedHANamingServiceMBean

setProxyFactoryObjectName

public void setProxyFactoryObjectName(javax.management.ObjectName proxyFactory)

Description copied from interface: DetachedHANamingServiceMBean

Set the proxy factory service name used to create the Naming transport proxy.

Specified by:

setProxyFactoryObjectName in interface DetachedHANamingServiceMBean

setPort

public void setPort(int p)

Description copied from interface: DetachedHANamingServiceMBean

Set the bootstrap port on which the HA-JNDI stub is made available

Specified by:

setPort in interface DetachedHANamingServiceMBean

getPort

public int getPort()

Description copied from interface: DetachedHANamingServiceMBean

Get the bootstrap port on which the HA-JNDI stub is made available

Specified by:

getPort in interface DetachedHANamingServiceMBean

getBindAddress

public String getBindAddress()

Description copied from interface: DetachedHANamingServiceMBean

Get the bootstrap IP address on which the HA-JNDI stub is made available

Specified by:

getBindAddress in interface DetachedHANamingServiceMBean

setBindAddress

public void setBindAddress(String host)
                    throws UnknownHostException

Description copied from interface: DetachedHANamingServiceMBean

Set the bootstrap IP address on which the HA-JNDI stub is made available

Specified by:

setBindAddress in interface DetachedHANamingServiceMBean

Throws:

UnknownHostException

getBacklog

public int getBacklog()

Description copied from interface: DetachedHANamingServiceMBean

Get the accept backlog for the bootstrap server socket

Specified by:

getBacklog in interface DetachedHANamingServiceMBean

setBacklog

public void setBacklog(int backlog)

Description copied from interface: DetachedHANamingServiceMBean

Set the accept backlog for the bootstrap server socket

Specified by:

setBacklog in interface DetachedHANamingServiceMBean

setDiscoveryDisabled

public void setDiscoveryDisabled(boolean disable)

Description copied from interface: DetachedHANamingServiceMBean

prevent autodiscovery service from starting

Specified by:

setDiscoveryDisabled in interface DetachedHANamingServiceMBean

getDiscoveryDisabled

public boolean getDiscoveryDisabled()

Description copied from interface: DetachedHANamingServiceMBean

prevent autodiscovery service from starting

Specified by:

getDiscoveryDisabled in interface DetachedHANamingServiceMBean

getAutoDiscoveryAddress

public String getAutoDiscoveryAddress()

Description copied from interface: DetachedHANamingServiceMBean

Get the auto-discovery bootstrap multicast address.

Specified by:

getAutoDiscoveryAddress in interface DetachedHANamingServiceMBean

setAutoDiscoveryAddress

public void setAutoDiscoveryAddress(String adAddress)

Description copied from interface: DetachedHANamingServiceMBean

Set the auto-discovery bootstrap multicast address. If null or empty, no auto-discovery bootstrap socket will be created.

Specified by:

setAutoDiscoveryAddress in interface DetachedHANamingServiceMBean

getAutoDiscoveryGroup

public int getAutoDiscoveryGroup()

Description copied from interface: DetachedHANamingServiceMBean

Get the Auto-discovery multicast port

Specified by:

getAutoDiscoveryGroup in interface DetachedHANamingServiceMBean

setAutoDiscoveryGroup

public void setAutoDiscoveryGroup(int adGroup)

Description copied from interface: DetachedHANamingServiceMBean

Set the Auto-discovery multicast port.

Specified by:

setAutoDiscoveryGroup in interface DetachedHANamingServiceMBean

getAutoDiscoveryBindAddress

public String getAutoDiscoveryBindAddress()

Description copied from interface: DetachedHANamingServiceMBean

Get the auto-discovery bootstrap multicast bind address.

Specified by:

getAutoDiscoveryBindAddress in interface DetachedHANamingServiceMBean

setAutoDiscoveryBindAddress

public void setAutoDiscoveryBindAddress(String address)
                                 throws UnknownHostException

Description copied from interface: DetachedHANamingServiceMBean

Set the auto-discovery bootstrap multicast bind address. If not specified and a BindAddress is specified, the BindAddress will be used.

Specified by:

setAutoDiscoveryBindAddress in interface DetachedHANamingServiceMBean

Throws:

UnknownHostException

getAutoDiscoveryTTL

public int getAutoDiscoveryTTL()

Description copied from interface: DetachedHANamingServiceMBean

Get the TTL (time-to-live) for autodiscovery IP multicast packets

Specified by:

getAutoDiscoveryTTL in interface DetachedHANamingServiceMBean

setAutoDiscoveryTTL

public void setAutoDiscoveryTTL(int ttl)

Description copied from interface: DetachedHANamingServiceMBean

Set the TTL (time-to-live) for autodiscovery IP multicast packets

Specified by:

setAutoDiscoveryTTL in interface DetachedHANamingServiceMBean

setJNPServerSocketFactory

public void setJNPServerSocketFactory(String factoryClassName)
                               throws ClassNotFoundException,
                                      InstantiationException,
                                      IllegalAccessException

Throws:

ClassNotFoundException

InstantiationException

IllegalAccessException

setLookupPool

public void setLookupPool(org.jboss.util.threadpool.BasicThreadPoolMBean poolMBean)

Description copied from interface: DetachedHANamingServiceMBean

Set the thread pool used for the bootstrap and autodiscovery lookups

Specified by:

setLookupPool in interface DetachedHANamingServiceMBean

startService

public void startService(HAPartition haPartition)
                  throws Exception

Throws:

Exception

createService

protected void createService()
                      throws Exception

Overrides:

createService in class org.jboss.system.ServiceMBeanSupport

Throws:

Exception

startService

protected void startService()
                     throws Exception

Overrides:

startService in class org.jboss.system.ServiceMBeanSupport

Throws:

Exception

stopService

protected void stopService()
                    throws Exception

Overrides:

stopService in class org.jboss.system.ServiceMBeanSupport

Throws:

Exception

destroyService

protected void destroyService()
                       throws Exception

Overrides:

destroyService in class org.jboss.system.ServiceMBeanSupport

Throws:

Exception

invoke

public Object invoke(org.jboss.invocation.Invocation invocation)
              throws Exception

Expose the Naming service via JMX to invokers.

Specified by:

invoke in interface DetachedHANamingServiceMBean

Parameters:

invocation - A pointer to the invocation object

Returns:

Return value of method invocation.

Throws:

Exception - Failed to invoke method.

initBootstrapListener

protected void initBootstrapListener()

Bring up the bootstrap lookup port for obtaining the naming service proxy

findHAPartitionWithName

protected HAPartition findHAPartitionWithName(String name)
                                       throws Exception

Throws:

Exception

getNamingProxy

protected org.jnp.interfaces.Naming getNamingProxy()
                                            throws Exception

Get the Naming proxy for the transport. This version looks up the proxyFactory service Proxy attribute. Subclasses can override this to set the proxy another way.

Returns:

The Naming proxy for the protocol used with the HAJNDI service

Throws:

Exception