org.apache.activemq.transport.discovery.simple
public class SimpleDiscoveryAgent extends java.lang.Object implements DiscoveryAgent
Constructor and Description |
---|
SimpleDiscoveryAgent() |
Modifier and Type | Method and Description |
---|---|
long |
getBackOffMultiplier() |
long |
getInitialReconnectDelay() |
int |
getMaxReconnectAttempts() |
long |
getMaxReconnectDelay() |
long |
getMinConnectTime() |
java.lang.String[] |
getServices() |
boolean |
isUseExponentialBackOff() |
void |
registerService(java.lang.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(java.lang.String services) |
void |
setServices(java.lang.String[] services) |
void |
setServices(java.net.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(java.lang.String name) throws java.io.IOException
DiscoveryAgent
registerService
in interface DiscoveryAgent
java.io.IOException
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public java.lang.String[] getServices()
public void setServices(java.lang.String services)
public void setServices(java.lang.String[] services)
public void setServices(java.net.URI[] services)
public void serviceFailed(DiscoveryEvent devent) throws java.io.IOException
DiscoveryAgent
serviceFailed
in interface DiscoveryAgent
java.io.IOException
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-2014. All Rights Reserved.