org.apache.openejb.server.discovery

Class MultipointDiscoveryAgent

java.lang.Object

org.apache.openejb.server.discovery.MultipointDiscoveryAgent

All Implemented Interfaces:

DiscoveryAgent, SelfManaging, ServerService, org.apache.openejb.spi.Service

public class MultipointDiscoveryAgent
extends Object
implements DiscoveryAgent, ServerService, SelfManaging

Version:

$Rev$ $Date$

Constructor Summary

Constructors

Constructor and Description
MultipointDiscoveryAgent()
MultipointDiscoveryAgent(boolean debug, String name)

Method Summary

Methods

Modifier and Type	Method and Description
List<URI>	getConnectionsQueued()
long	getHeartbeats()
String	getHeartbeatsLatest()
long	getHeartbeatsLatestTime()
String	getHost()
String	getInitialServers()
String	getIP()
long	getJoined()
String	getName()
int	getPort()
long	getReconnectDelay()
long	getReconnects()
String	getReconnectsLatest()
long	getReconnectsLatestTime()
Set<URI>	getRoots()
long	getRuns()
String	getRunsLatest()
long	getRunsLatestTime()
List<URI>	getSessions()
long	getSessionsCreated()
String	getSessionsCreatedLatest()
long	getSessionsCreatedLatestTime()
URI	getURI()
void	init(Properties props)
static void	main(String[] args)
void	registerService(URI serviceUri)
void	reportFailed(URI serviceUri)
void	restart()
void	service(InputStream in, OutputStream out)
void	service(Socket socket)
void	setDiscoveryListener(DiscoveryListener listener)
void	setHost(String host)
void	start() start the discovery agent
void	stop() stop the channel
void	unregisterService(URI serviceUri)

Methods inherited from class java.lang.Object

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

Constructor Detail

MultipointDiscoveryAgent

public MultipointDiscoveryAgent()

MultipointDiscoveryAgent

public MultipointDiscoveryAgent(boolean debug,
                        String name)

Method Detail

init

public void init(Properties props)

Specified by:

init in interface org.apache.openejb.spi.Service

getIP

public String getIP()

Specified by:

getIP in interface ServerService

getName

public String getName()

Specified by:

getName in interface ServerService

getPort

public int getPort()

Specified by:

getPort in interface ServerService

getInitialServers

public String getInitialServers()

setDiscoveryListener

public void setDiscoveryListener(DiscoveryListener listener)

Specified by:

setDiscoveryListener in interface DiscoveryAgent

registerService

public void registerService(URI serviceUri)
                     throws IOException

Specified by:

registerService in interface DiscoveryAgent

Throws:

IOException

unregisterService

public void unregisterService(URI serviceUri)
                       throws IOException

Specified by:

unregisterService in interface DiscoveryAgent

Throws:

IOException

reportFailed

public void reportFailed(URI serviceUri)

Specified by:

reportFailed in interface DiscoveryAgent

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

start

public void start()
           throws ServiceException

start the discovery agent

Specified by:

start in interface ServerService

Throws:

ServiceException - On error

restart

public void restart()
             throws ServiceException

Throws:

ServiceException

stop

public void stop()
          throws ServiceException

stop the channel

Specified by:

stop in interface ServerService

Throws:

ServiceException - On error

service

public void service(InputStream in,
           OutputStream out)
             throws ServiceException,
                    IOException

Specified by:

service in interface ServerService

Throws:

ServiceException

IOException

service

public void service(Socket socket)
             throws ServiceException,
                    IOException

Specified by:

service in interface ServerService

Throws:

ServiceException

IOException

getHost

public String getHost()

setHost

public void setHost(String host)

getURI

public URI getURI()

getRoots

public Set<URI> getRoots()

getRuns

public long getRuns()

getRunsLatest

public String getRunsLatest()

getRunsLatestTime

public long getRunsLatestTime()

getHeartbeats

public long getHeartbeats()

getHeartbeatsLatest

public String getHeartbeatsLatest()

getHeartbeatsLatestTime

public long getHeartbeatsLatestTime()

getSessionsCreated

public long getSessionsCreated()

getSessionsCreatedLatest

public String getSessionsCreatedLatest()

getSessionsCreatedLatestTime

public long getSessionsCreatedLatestTime()

getReconnects

public long getReconnects()

getReconnectsLatest

public String getReconnectsLatest()

getReconnectsLatestTime

public long getReconnectsLatestTime()

getJoined

public long getJoined()

getSessions

public List<URI> getSessions()

getConnectionsQueued

public List<URI> getConnectionsQueued()

getReconnectDelay

public long getReconnectDelay()