|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.discovery.simple.SimpleDiscoveryAgent
public class SimpleDiscoveryAgent
A simple DiscoveryAgent that allows static configuration of the discovered services.
Constructor Summary | |
---|---|
SimpleDiscoveryAgent()
|
Method Summary | |
---|---|
long |
getBackOffMultiplier()
|
java.lang.String |
getGroup()
|
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 |
setBrokerName(java.lang.String brokerName)
|
void |
setDiscoveryListener(DiscoveryListener listener)
Sets the discovery listener |
void |
setGroup(java.lang.String group)
|
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()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public SimpleDiscoveryAgent()
Method Detail |
---|
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
start
in interface Service
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
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 java.lang.String getGroup()
getGroup
in interface DiscoveryAgent
public void setGroup(java.lang.String group)
setGroup
in interface DiscoveryAgent
public void setBrokerName(java.lang.String brokerName)
setBrokerName
in interface DiscoveryAgent
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)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |