org.objectweb.jonas.discovery.internal
Class DiscoveryServiceImpl

java.lang.Object
  javax.management.NotificationBroadcasterSupport
      org.objectweb.jonas.management.reconfig.emitter.ReconfigEmitter
          org.objectweb.jonas.service.AbsServiceImpl
              org.objectweb.jonas.discovery.internal.DiscoveryServiceImpl

All Implemented Interfaces:

NotificationBroadcaster, NotificationEmitter, org.objectweb.jonas.discovery.DiscoveryService, DiscoveryServiceImplMBean, org.objectweb.jonas.service.Service

public class DiscoveryServiceImpl
extends org.objectweb.jonas.service.AbsServiceImpl
implements org.objectweb.jonas.discovery.DiscoveryService, DiscoveryServiceImplMBean

Author:

Adriana Danes The discovery service creates and starts at least a DiscoveryManager which is a MBean that multicasts discovery information to all the servers who joined the discovery multicast group.

The discovery service may also create a Enroller and a DiscoveryClient, and in this case the current server becomes a discovery server.

Discovery information contains information allowing to remotely manage a server in the group.

Discovery multicast group is a group of servers which can be managed remotely by a discovery server.

Discovery server is the server in the group who detains the discovery information concerning all the servers in the group.

Field Summary

Fields inherited from class org.objectweb.jonas.management.reconfig.emitter.ReconfigEmitter

RECONFIG_TYPE, SAVE_RECONFIG_TYPE

Constructor Summary

DiscoveryServiceImpl()

Method Summary

protected void	doInit(Context ctx) Initialize the discovery service.
protected void	doStart() Start the discovery service
protected void	doStop() Stop the discovery service
DiscEvent	getDiscEvent(String serverName, String domainName, String[] connectorURLs, String state) Create a 'fake' DiscEvent object containing info to establish a JMX connection with a new server in the domain
String	getDiscoveryProtocolVersion()
String	getDiscoveryTtl()
Boolean	getIsDiscoveryMaster()
String	getMulticastAddress()
String	getMulticastPort()
void	startDiscoveryMaster() Management operation allowing to make the current server become a master if its not already.

Methods inherited from class org.objectweb.jonas.service.AbsServiceImpl

getDomainName, getJonasServerName, getName, init, isStarted, setName, start, stop

Methods inherited from class org.objectweb.jonas.management.reconfig.emitter.ReconfigEmitter

initLogger, sendReconfigNotification, sendSaveNotification

Methods inherited from class javax.management.NotificationBroadcasterSupport

addNotificationListener, getNotificationInfo, handleNotification, 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.objectweb.jonas.service.Service

getName, init, isStarted, setName, start, stop

Constructor Detail

DiscoveryServiceImpl

public DiscoveryServiceImpl()

Method Detail

getMulticastAddress

public String getMulticastAddress()

Specified by:

getMulticastAddress in interface DiscoveryServiceImplMBean

Returns:

the multicast group IP address used by the discovery service

getMulticastPort

public String getMulticastPort()

Specified by:

getMulticastPort in interface DiscoveryServiceImplMBean

Returns:

the multicast group port number used by the discovery service

getIsDiscoveryMaster

public Boolean getIsDiscoveryMaster()

Specified by:

getIsDiscoveryMaster in interface DiscoveryServiceImplMBean

Returns:

true if the current server is a discovery server

startDiscoveryMaster

public void startDiscoveryMaster()
                          throws JMException

Management operation allowing to make the current server become a master if its not already.

Specified by:

startDiscoveryMaster in interface DiscoveryServiceImplMBean

Throws:

JMException - a JMX exception occured when trying to make current server a discovery master

doInit

protected void doInit(Context ctx)
               throws org.objectweb.jonas.service.ServiceException

Initialize the discovery service.

Specified by:

doInit in class org.objectweb.jonas.service.AbsServiceImpl

Parameters:

ctx - context containing initialization parameters

Throws:

org.objectweb.jonas.service.ServiceException - discovery service could not be correctly initialized

doStart

protected void doStart()
                throws org.objectweb.jonas.service.ServiceException

Start the discovery service

Specified by:

doStart in class org.objectweb.jonas.service.AbsServiceImpl

Throws:

org.objectweb.jonas.service.ServiceException - An error occured when starting the service

doStop

protected void doStop()
               throws org.objectweb.jonas.service.ServiceException

Stop the discovery service

Specified by:

doStop in class org.objectweb.jonas.service.AbsServiceImpl

Throws:

org.objectweb.jonas.service.ServiceException

getDiscEvent

public DiscEvent getDiscEvent(String serverName,
                              String domainName,
                              String[] connectorURLs,
                              String state)

Create a 'fake' DiscEvent object containing info to establish a JMX connection with a new server in the domain

Parameters:

serverName - the OBJECT_NAME of the server MBean corresponding to the server to connect

domainName - the JOnAS server's domain name

connectorURLs - the urls of the connector server of the server to connect

state - the state of the server (RUNNING in case the DiscEvent is used to add a server; could be STOPPING if the DiscEvent is used to remove a server)

Returns:

a new DiscEvent object

getDiscoveryProtocolVersion

public String getDiscoveryProtocolVersion()

Specified by:

getDiscoveryProtocolVersion in interface DiscoveryServiceImplMBean

Returns:

the discovery protocol version number

getDiscoveryTtl

public String getDiscoveryTtl()

Specified by:

getDiscoveryTtl in interface DiscoveryServiceImplMBean

Returns:

Returns the discovery Time to live

See Also:

DiscoveryServiceImplMBean.getDiscoveryTtl()