public class SimpleDiscoveryAgent extends Object implements DiscoveryAgent
Constructor and Description |
---|
SimpleDiscoveryAgent() |
Modifier and Type | Method and Description |
---|---|
protected void |
doReconnectDelay(org.apache.activemq.transport.discovery.simple.SimpleDiscoveryAgent.SimpleDiscoveryEvent event) |
long |
getBackOffMultiplier() |
long |
getInitialReconnectDelay() |
int |
getMaxReconnectAttempts() |
long |
getMaxReconnectDelay() |
long |
getMinConnectTime() |
String[] |
getServices() |
boolean |
isUseExponentialBackOff() |
void |
registerService(String name)
register a service
|
void |
serviceFailed(DiscoveryEvent devent)
A process actively using a service may see it go down before the DiscoveryAgent notices the
service's failure.
|
void |
setBackOffMultiplier(long backOffMultiplier) |
void |
setDiscoveryListener(DiscoveryListener listener)
Sets the discovery listener
|
void |
setInitialReconnectDelay(long initialReconnectDelay) |
void |
setMaxReconnectAttempts(int maxReconnectAttempts) |
void |
setMaxReconnectDelay(long maxReconnectDelay) |
void |
setMinConnectTime(long minConnectTime) |
void |
setServices(String services) |
void |
setServices(String[] services) |
void |
setServices(URI[] services) |
void |
setUseExponentialBackOff(boolean useExponentialBackOff) |
void |
start() |
void |
stop() |
public SimpleDiscoveryAgent()
public void setDiscoveryListener(DiscoveryListener listener)
DiscoveryAgent
setDiscoveryListener
in interface DiscoveryAgent
public void registerService(String name) throws IOException
DiscoveryAgent
registerService
in interface DiscoveryAgent
IOException
public String[] getServices()
public void setServices(String services)
public void setServices(String[] services)
public void setServices(URI[] services)
public void serviceFailed(DiscoveryEvent devent) throws IOException
DiscoveryAgent
serviceFailed
in interface DiscoveryAgent
IOException
protected void doReconnectDelay(org.apache.activemq.transport.discovery.simple.SimpleDiscoveryAgent.SimpleDiscoveryEvent event)
public long getBackOffMultiplier()
public void setBackOffMultiplier(long backOffMultiplier)
public long getInitialReconnectDelay()
public void setInitialReconnectDelay(long initialReconnectDelay)
public int getMaxReconnectAttempts()
public void setMaxReconnectAttempts(int maxReconnectAttempts)
public long getMaxReconnectDelay()
public void setMaxReconnectDelay(long maxReconnectDelay)
public long getMinConnectTime()
public void setMinConnectTime(long minConnectTime)
public boolean isUseExponentialBackOff()
public void setUseExponentialBackOff(boolean useExponentialBackOff)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.