|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent
public class MulticastDiscoveryAgent
A DiscoveryAgent
using a multicast address and heartbeat packets encoded using any
wireformat, but openwire by default.
Field Summary | |
---|---|
static String |
DEFAULT_DISCOVERY_URI_STRING
|
Constructor Summary | |
---|---|
MulticastDiscoveryAgent()
|
Method Summary | |
---|---|
String |
getBrokerName()
|
URI |
getDiscoveryURI()
|
String |
getGroup()
Get the group used for discovery |
long |
getKeepAliveInterval()
|
int |
getTimeToLive()
|
String |
getType()
|
boolean |
isLoopBackMode()
|
void |
registerService(String name)
register a service |
void |
run()
|
void |
serviceFailed(DiscoveryEvent event)
A process actively using a service may see it go down before the DiscoveryAgent notices the service's failure. |
void |
setBrokerName(String brokerName)
|
void |
setDiscoveryListener(DiscoveryListener listener)
Set the discovery listener |
void |
setDiscoveryURI(URI discoveryURI)
Set the discoveryURI |
void |
setGroup(String group)
Set the group for discovery |
void |
setKeepAliveInterval(long keepAliveInterval)
|
void |
setLoopBackMode(boolean loopBackMode)
|
void |
setTimeToLive(int timeToLive)
|
void |
start()
start the discovery agent |
void |
stop()
stop the channel |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String DEFAULT_DISCOVERY_URI_STRING
Constructor Detail |
---|
public MulticastDiscoveryAgent()
Method Detail |
---|
public void setDiscoveryListener(DiscoveryListener listener)
setDiscoveryListener
in interface DiscoveryAgent
listener
- public void registerService(String name) throws IOException
registerService
in interface DiscoveryAgent
IOException
public String getGroup()
getGroup
in interface DiscoveryAgent
public void setGroup(String group)
setGroup
in interface DiscoveryAgent
group
- public String getBrokerName()
public void setBrokerName(String brokerName)
setBrokerName
in interface DiscoveryAgent
brokerName
- The brokerName to set.public boolean isLoopBackMode()
public void setLoopBackMode(boolean loopBackMode)
loopBackMode
- The loopBackMode to set.public int getTimeToLive()
public void setTimeToLive(int timeToLive)
timeToLive
- The timeToLive to set.public URI getDiscoveryURI()
public void setDiscoveryURI(URI discoveryURI)
discoveryURI
- public long getKeepAliveInterval()
public void setKeepAliveInterval(long keepAliveInterval)
public void start() throws Exception
start
in interface Service
Exception
public void stop() throws Exception
stop
in interface Service
Exception
public String getType()
public void run()
run
in interface Runnable
public void serviceFailed(DiscoveryEvent event) throws IOException
DiscoveryAgent
serviceFailed
in interface DiscoveryAgent
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |