|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.transport.DiscoveryAgentSupport
org.activemq.transport.multicast.MulticastDiscoveryAgent
An agent used to discover other instances of a service
Field Summary | |
static String |
DEFAULT_DISCOVERY_URI
default URI used for discovery |
Fields inherited from class org.activemq.transport.DiscoveryAgentSupport |
listeners |
Constructor Summary | |
MulticastDiscoveryAgent(String channelName)
Construct a discovery agent that uses multicast |
|
MulticastDiscoveryAgent(URI uri)
|
Method Summary | |
void |
consume(Packet packet)
Consume multicast packets |
String |
getChannelName()
|
long |
getKeepAliveTimeout()
|
String |
getLocalId()
|
int |
getServicesCount()
|
int |
getTimeoutCount()
|
int |
getTimeToLive()
|
URI |
getUri()
|
void |
registerService(String name,
Map details)
Register a service for other discover nodes |
void |
run()
send a keep alive message |
void |
setChannelName(String channelName)
|
void |
setKeepAliveTimeout(long keepAliveTimeout)
|
void |
setLocalId(String localId)
|
void |
setTimeoutCount(int timeoutCount)
|
void |
setTimeToLive(int timeToLive)
|
void |
setUri(URI uri)
|
void |
start()
start this discovery agent |
void |
stop()
stop this discovery agent |
String |
toString()
|
Methods inherited from class org.activemq.transport.DiscoveryAgentSupport |
addDiscoveryListener, fireAddService, fireRemoveService, removeDiscoveryListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public static final String DEFAULT_DISCOVERY_URI
Constructor Detail |
public MulticastDiscoveryAgent(String channelName) throws JMSException
channelName
-
JMSException
public MulticastDiscoveryAgent(URI uri)
Method Detail |
public long getKeepAliveTimeout()
public void setKeepAliveTimeout(long keepAliveTimeout)
keepAliveTimeout
- The keepAliveTimeout to set.public int getTimeoutCount()
public void setTimeoutCount(int timeoutCount)
timeoutCount
- The timeoutCount to set.public String getLocalId()
public void setLocalId(String localId)
localId
- The localId to set.public URI getUri()
public void setUri(URI uri)
uri
- The uri to set.public int getTimeToLive()
public void setTimeToLive(int timeToLive) throws IOException
timeToLive
- The timeToLive for multicast packets used in discovery.
IOException
public String getChannelName()
public void setChannelName(String channelName)
channelName
- The channelName to set.public String toString()
public int getServicesCount()
public void registerService(String name, Map details) throws JMSException
registerService
in interface DiscoveryAgent
name
- details
-
JMSException
public void start() throws JMSException
start
in interface Service
JMSException
public void stop() throws JMSException
stop
in interface Service
JMSException
public void run()
run
in interface Runnable
public void consume(Packet packet)
consume
in interface PacketListener
packet
-
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |