|
||||||||||
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 java.lang.String |
DEFAULT_DISCOVERY_URI_STRING
|
Constructor Summary | |
---|---|
MulticastDiscoveryAgent()
|
Method Summary | |
---|---|
java.lang.String |
getBrokerName()
|
java.net.URI |
getDiscoveryURI()
|
java.lang.String |
getGroup()
Get the group used for discovery |
long |
getKeepAliveInterval()
|
int |
getTimeToLive()
|
java.lang.String |
getType()
|
boolean |
isLoopBackMode()
|
void |
registerService(java.lang.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(java.lang.String brokerName)
|
void |
setDiscoveryListener(DiscoveryListener listener)
Set the discovery listener |
void |
setDiscoveryURI(java.net.URI discoveryURI)
Set the discoveryURI |
void |
setGroup(java.lang.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 java.lang.String DEFAULT_DISCOVERY_URI_STRING
Constructor Detail |
---|
public MulticastDiscoveryAgent()
Method Detail |
---|
public void setDiscoveryListener(DiscoveryListener listener)
setDiscoveryListener
in interface DiscoveryAgent
listener
- public void registerService(java.lang.String name) throws java.io.IOException
registerService
in interface DiscoveryAgent
java.io.IOException
public java.lang.String getGroup()
getGroup
in interface DiscoveryAgent
public void setGroup(java.lang.String group)
setGroup
in interface DiscoveryAgent
group
- public java.lang.String getBrokerName()
public void setBrokerName(java.lang.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 java.net.URI getDiscoveryURI()
public void setDiscoveryURI(java.net.URI discoveryURI)
discoveryURI
- public long getKeepAliveInterval()
public void setKeepAliveInterval(long keepAliveInterval)
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 getType()
public void run()
run
in interface java.lang.Runnable
public void serviceFailed(DiscoveryEvent event) throws java.io.IOException
DiscoveryAgent
serviceFailed
in interface DiscoveryAgent
java.io.IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |