public class HTTPDiscoveryAgent extends Object implements org.apache.activemq.transport.discovery.DiscoveryAgent, org.apache.activemq.util.Suspendable
Constructor and Description |
---|
HTTPDiscoveryAgent() |
Modifier and Type | Method and Description |
---|---|
String |
getGroup() |
String |
getRegistryURL() |
long |
getUpdateInterval() |
boolean |
isStartEmbeddRegistry() |
void |
registerService(String service) |
void |
resume() |
void |
serviceFailed(org.apache.activemq.command.DiscoveryEvent devent) |
void |
setBrokerName(String brokerName) |
void |
setDiscoveryListener(org.apache.activemq.transport.discovery.DiscoveryListener discoveryListener) |
void |
setGroup(String group) |
void |
setRegistryURL(String discoveryRegistryURL) |
void |
setStartEmbeddRegistry(boolean startEmbeddRegistry) |
void |
setUpdateInterval(long updateInterval) |
void |
start() |
void |
stop() |
void |
suspend() |
public HTTPDiscoveryAgent()
public void registerService(String service) throws IOException
registerService
in interface org.apache.activemq.transport.discovery.DiscoveryAgent
IOException
public void serviceFailed(org.apache.activemq.command.DiscoveryEvent devent) throws IOException
serviceFailed
in interface org.apache.activemq.transport.discovery.DiscoveryAgent
IOException
public void setBrokerName(String brokerName)
public void setDiscoveryListener(org.apache.activemq.transport.discovery.DiscoveryListener discoveryListener)
setDiscoveryListener
in interface org.apache.activemq.transport.discovery.DiscoveryAgent
public void start() throws Exception
start
in interface org.apache.activemq.Service
Exception
public void stop() throws Exception
stop
in interface org.apache.activemq.Service
Exception
public String getRegistryURL()
public void setRegistryURL(String discoveryRegistryURL)
public long getUpdateInterval()
public void setUpdateInterval(long updateInterval)
public boolean isStartEmbeddRegistry()
public void setStartEmbeddRegistry(boolean startEmbeddRegistry)
public void suspend() throws Exception
suspend
in interface org.apache.activemq.util.Suspendable
Exception
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.