Constructor Detail

• MultipointDiscoveryAgent

  public MultipointDiscoveryAgent()

• MultipointDiscoveryAgent

  public MultipointDiscoveryAgent(boolean debug,
                                  java.lang.String name)

Method Detail

• init

  public void init(java.util.Properties props)

  Specified by:

  init in interface Service

• getIP

  public java.lang.String getIP()

  Specified by:

  getIP in interface ServerService

• getName

  public java.lang.String getName()

  Specified by:

  getName in interface ServerService

• getPort

  public int getPort()

  Specified by:

  getPort in interface ServerService

• getInitialServers

  public java.lang.String getInitialServers()

• setDiscoveryListener

  public void setDiscoveryListener(DiscoveryListener listener)

  Description copied from interface: DiscoveryAgent
  Sets the discovery listener

  Specified by:

  setDiscoveryListener in interface DiscoveryAgent

• registerService

  public void registerService(java.net.URI serviceUri)
                       throws java.io.IOException

  Description copied from interface: DiscoveryAgent
  register a service

  Specified by:

  registerService in interface DiscoveryAgent

  Throws:

  java.io.IOException

• unregisterService

  public void unregisterService(java.net.URI serviceUri)
                         throws java.io.IOException

  Description copied from interface: DiscoveryAgent
  register a service

  Specified by:

  unregisterService in interface DiscoveryAgent

  Throws:

  java.io.IOException

• reportFailed

  public void reportFailed(java.net.URI serviceUri)

  Description copied from interface: DiscoveryAgent
  A process actively using a service may see it go down before the DiscoveryAgent notices the service's failure. That process can use this method to notify the DiscoveryAgent of the failure so that other listeners of this DiscoveryAgent can also be made aware of the failure.

  Specified by:

  reportFailed in interface DiscoveryAgent

• main

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

  Throws:

  java.lang.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(java.io.InputStream in,
                      java.io.OutputStream out)
               throws ServiceException,
                      java.io.IOException

  Specified by:

  service in interface ServerService

  Throws:

  ServiceException

  java.io.IOException

• service

  public void service(java.net.Socket socket)
               throws ServiceException,
                      java.io.IOException

  Specified by:

  service in interface ServerService

  Throws:

  ServiceException

  java.io.IOException

• getHost

  public java.lang.String getHost()

• setHost

  public void setHost(java.lang.String host)

• getURI

  public java.net.URI getURI()

• getRoots

  public java.util.Set<java.net.URI> getRoots()

• getRuns

  public long getRuns()

• getRunsLatest

  public java.lang.String getRunsLatest()

• getRunsLatestTime

  public long getRunsLatestTime()

• getHeartbeats

  public long getHeartbeats()

• getHeartbeatsLatest

  public java.lang.String getHeartbeatsLatest()

• getHeartbeatsLatestTime

  public long getHeartbeatsLatestTime()

• getSessionsCreated

  public long getSessionsCreated()

• getSessionsCreatedLatest

  public java.lang.String getSessionsCreatedLatest()

• getSessionsCreatedLatestTime

  public long getSessionsCreatedLatestTime()

• getReconnects

  public long getReconnects()

• getReconnectsLatest

  public java.lang.String getReconnectsLatest()

• getReconnectsLatestTime

  public long getReconnectsLatestTime()

• getJoined

  public long getJoined()

• getSessions

  public java.util.List<java.net.URI> getSessions()

• getConnectionsQueued

  public java.util.List<java.net.URI> getConnectionsQueued()

• getReconnectDelay

  public long getReconnectDelay()