Home » activemq-parent-5.3.1-source-release » org.apache » activemq » transport » discovery » multicast » [javadoc | source]
org.apache.activemq.transport.discovery.multicast
public class: MulticastDiscoveryAgent [javadoc | source]
java.lang.Object
   org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent

All Implemented Interfaces:
    DiscoveryAgent, Runnable

A DiscoveryAgent using a multicast address and heartbeat packets encoded using any wireformat, but openwire by default.
Nested Class Summary:
class  MulticastDiscoveryAgent.RemoteBrokerData   
Field Summary
public static final  String DEFAULT_DISCOVERY_URI_STRING     
public static final  String DEFAULT_HOST_STR     
public static final  String DEFAULT_HOST_IP     
public static final  int DEFAULT_PORT     
Method from org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent Summary:
getBackOffMultiplier,   getDiscoveryURI,   getInitialReconnectDelay,   getKeepAliveInterval,   getMaxReconnectAttempts,   getMaxReconnectDelay,   getTimeToLive,   getType,   isLoopBackMode,   isUseExponentialBackOff,   registerService,   run,   serviceFailed,   setBackOffMultiplier,   setDiscoveryListener,   setDiscoveryURI,   setGroup,   setInitialReconnectDelay,   setInterface,   setKeepAliveInterval,   setLoopBackMode,   setMaxReconnectAttempts,   setMaxReconnectDelay,   setNetworkInterface,   setTimeToLive,   setUseExponentialBackOff,   start,   stop,   toString
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent Detail:
 public long getBackOffMultiplier() 
 public URI getDiscoveryURI() 
 public long getInitialReconnectDelay() 
 public long getKeepAliveInterval() 
 public int getMaxReconnectAttempts() 
 public long getMaxReconnectDelay() 
 public int getTimeToLive() 
 public String getType() 
 public boolean isLoopBackMode() 
 public boolean isUseExponentialBackOff() 
 public  void registerService(String name) throws IOException 
    register a service
 public  void run() 
 public  void serviceFailed(DiscoveryEvent event) throws IOException 
 public  void setBackOffMultiplier(long backOffMultiplier) 
 public  void setDiscoveryListener(DiscoveryListener listener) 
    Set the discovery listener
 public  void setDiscoveryURI(URI discoveryURI) 
    Set the discoveryURI
 public  void setGroup(String group) 
 public  void setInitialReconnectDelay(long initialReconnectDelay) 
 public  void setInterface(String mcInterface) 
 public  void setKeepAliveInterval(long keepAliveInterval) 
 public  void setLoopBackMode(boolean loopBackMode) 
 public  void setMaxReconnectAttempts(int maxReconnectAttempts) 
 public  void setMaxReconnectDelay(long maxReconnectDelay) 
 public  void setNetworkInterface(String mcNetworkInterface) 
 public  void setTimeToLive(int timeToLive) 
 public  void setUseExponentialBackOff(boolean useExponentialBackOff) 
 public  void start() throws Exception 
    start the discovery agent
 public  void stop() throws Exception 
    stop the channel
 public String toString()