org.apache.activemq.transport.discovery.http
Class HTTPDiscoveryAgent

java.lang.Object
  extended by org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent
All Implemented Interfaces:
Service, DiscoveryAgent, Suspendable

public class HTTPDiscoveryAgent
extends Object
implements DiscoveryAgent, Suspendable


Constructor Summary
HTTPDiscoveryAgent()
           
 
Method Summary
 String getGroup()
           
 String getRegistryURL()
           
 long getUpdateInterval()
           
 boolean isStartEmbeddRegistry()
           
 void registerService(String service)
          register a service
 void resume()
           
 void serviceFailed(DiscoveryEvent devent)
          A process actively using a service may see it go down before the DiscoveryAgent notices the service's failure.
 void setBrokerName(String brokerName)
           
 void setDiscoveryListener(DiscoveryListener discoveryListener)
          Sets the discovery listener
 void setGroup(String group)
           
 void setRegistryURL(String discoveryRegistryURL)
           
 void setStartEmbeddRegistry(boolean startEmbeddRegistry)
           
 void setUpdateInterval(long updateInterval)
           
 void start()
           
 void stop()
           
 void suspend()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HTTPDiscoveryAgent

public HTTPDiscoveryAgent()
Method Detail

getGroup

public String getGroup()

registerService

public void registerService(String service)
                     throws IOException
Description copied from interface: DiscoveryAgent
register a service

Specified by:
registerService in interface DiscoveryAgent
Throws:
IOException

serviceFailed

public void serviceFailed(DiscoveryEvent devent)
                   throws IOException
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:
serviceFailed in interface DiscoveryAgent
Throws:
IOException

setBrokerName

public void setBrokerName(String brokerName)

setDiscoveryListener

public void setDiscoveryListener(DiscoveryListener discoveryListener)
Description copied from interface: DiscoveryAgent
Sets the discovery listener

Specified by:
setDiscoveryListener in interface DiscoveryAgent

setGroup

public void setGroup(String group)

start

public void start()
           throws Exception
Specified by:
start in interface Service
Throws:
Exception

stop

public void stop()
          throws Exception
Specified by:
stop in interface Service
Throws:
Exception

getRegistryURL

public String getRegistryURL()

setRegistryURL

public void setRegistryURL(String discoveryRegistryURL)

getUpdateInterval

public long getUpdateInterval()

setUpdateInterval

public void setUpdateInterval(long updateInterval)

isStartEmbeddRegistry

public boolean isStartEmbeddRegistry()

setStartEmbeddRegistry

public void setStartEmbeddRegistry(boolean startEmbeddRegistry)

suspend

public void suspend()
             throws Exception
Specified by:
suspend in interface Suspendable
Throws:
Exception

resume

public void resume()
            throws Exception
Specified by:
resume in interface Suspendable
Throws:
Exception


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.