org.apache.activemq.transport.discovery.http
Class HTTPDiscoveryAgent
java.lang.Object
org.apache.activemq.transport.discovery.http.HTTPDiscoveryAgent
- All Implemented Interfaces:
- Service, DiscoveryAgent
public class HTTPDiscoveryAgent
- extends Object
- implements DiscoveryAgent
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HTTPDiscoveryAgent
public HTTPDiscoveryAgent()
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)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.