public class MulticastDiscoveryAgent extends java.lang.Object implements DiscoveryAgent, java.lang.Runnable
DiscoveryAgent
using a multicast address and heartbeat packets
encoded using any wireformat, but openwire by default.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEFAULT_DISCOVERY_URI_STRING |
static java.lang.String |
DEFAULT_HOST_IP |
static java.lang.String |
DEFAULT_HOST_STR |
static int |
DEFAULT_PORT |
Constructor and Description |
---|
MulticastDiscoveryAgent() |
Modifier and Type | Method and Description |
---|---|
long |
getBackOffMultiplier() |
java.net.URI |
getDiscoveryURI() |
long |
getInitialReconnectDelay() |
long |
getKeepAliveInterval() |
int |
getMaxReconnectAttempts() |
long |
getMaxReconnectDelay() |
int |
getTimeToLive() |
java.lang.String |
getType() |
boolean |
isLoopBackMode() |
boolean |
isUseExponentialBackOff() |
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 |
setBackOffMultiplier(long backOffMultiplier) |
void |
setDiscoveryListener(DiscoveryListener listener)
Set the discovery listener
|
void |
setDiscoveryURI(java.net.URI discoveryURI)
Set the discoveryURI
|
void |
setGroup(java.lang.String group) |
void |
setInitialReconnectDelay(long initialReconnectDelay) |
void |
setInterface(java.lang.String mcInterface) |
void |
setJoinNetworkInterface(java.lang.String mcJoinNetwrokInterface) |
void |
setKeepAliveInterval(long keepAliveInterval) |
void |
setLoopBackMode(boolean loopBackMode) |
void |
setMaxReconnectAttempts(int maxReconnectAttempts) |
void |
setMaxReconnectDelay(long maxReconnectDelay) |
void |
setNetworkInterface(java.lang.String mcNetworkInterface) |
void |
setTimeToLive(int timeToLive) |
void |
setUseExponentialBackOff(boolean useExponentialBackOff) |
void |
start()
start the discovery agent
|
void |
stop()
stop the channel
|
java.lang.String |
toString() |
public static final java.lang.String DEFAULT_DISCOVERY_URI_STRING
public static final java.lang.String DEFAULT_HOST_STR
public static final java.lang.String DEFAULT_HOST_IP
public static final int DEFAULT_PORT
public MulticastDiscoveryAgent()
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 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 setInterface(java.lang.String mcInterface)
public void setNetworkInterface(java.lang.String mcNetworkInterface)
public void setJoinNetworkInterface(java.lang.String mcJoinNetwrokInterface)
public void start() throws java.lang.Exception
public void stop() throws 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
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 boolean isUseExponentialBackOff()
public void setUseExponentialBackOff(boolean useExponentialBackOff)
public void setGroup(java.lang.String group)
public java.lang.String toString()
toString
in class java.lang.Object
Copyright © 2005-2017. All Rights Reserved.