org.apache.activemq.network
Class DiscoveryNetworkConnector

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by org.apache.activemq.network.NetworkConnector
          extended by org.apache.activemq.network.DiscoveryNetworkConnector
All Implemented Interfaces:
Service, DiscoveryListener

public class DiscoveryNetworkConnector
extends NetworkConnector
implements DiscoveryListener

A network connector which uses a discovery agent to detect the remote brokers available and setup a connection to each available remote broker

Version:
$Revision: 426366 $

Field Summary
 
Fields inherited from class org.apache.activemq.network.NetworkConnector
conduitSubscriptions, connectionFilter, dynamicOnly, failover, localURI, log
 
Constructor Summary
DiscoveryNetworkConnector()
           
DiscoveryNetworkConnector(java.net.URI discoveryURI)
           
 
Method Summary
protected  Bridge createBridge(Transport localTransport, Transport remoteTransport, DiscoveryEvent event)
           
protected  java.lang.String createName()
           
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
 DiscoveryAgent getDiscoveryAgent()
           
 boolean isFailover()
           
 void onServiceAdd(DiscoveryEvent event)
           
 void onServiceRemove(DiscoveryEvent event)
           
 void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
           
 void setFailover(boolean reliable)
           
 void setUri(java.net.URI discoveryURI)
           
 
Methods inherited from class org.apache.activemq.network.NetworkConnector
addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, getBrokerName, getConnectionFilter, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalUri, getName, getNetworkTTL, getPassword, getPrefetchSize, getStaticallyIncludedDestinations, getUserName, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDynamicOnly, setBridgeTempDestinations, setBrokerName, setConduitSubscriptions, setConnectionFilter, setDecreaseNetworkConsumerPriority, setDispatchAsync, setDurableDestinations, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setLocalUri, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticallyIncludedDestinations, setUserName
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
dispose, isStarted, isStopped, isStopping, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DiscoveryNetworkConnector

public DiscoveryNetworkConnector()

DiscoveryNetworkConnector

public DiscoveryNetworkConnector(java.net.URI discoveryURI)
                          throws java.io.IOException
Throws:
java.io.IOException
Method Detail

setUri

public void setUri(java.net.URI discoveryURI)
            throws java.io.IOException
Throws:
java.io.IOException

onServiceAdd

public void onServiceAdd(DiscoveryEvent event)
Specified by:
onServiceAdd in interface DiscoveryListener

onServiceRemove

public void onServiceRemove(DiscoveryEvent event)
Specified by:
onServiceRemove in interface DiscoveryListener

getDiscoveryAgent

public DiscoveryAgent getDiscoveryAgent()

setDiscoveryAgent

public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)

isFailover

public boolean isFailover()

setFailover

public void setFailover(boolean reliable)

doStart

protected void doStart()
                throws java.lang.Exception
Overrides:
doStart in class NetworkConnector
Throws:
java.lang.Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception
Overrides:
doStop in class NetworkConnector
Throws:
java.lang.Exception

createBridge

protected Bridge createBridge(Transport localTransport,
                              Transport remoteTransport,
                              DiscoveryEvent event)

createName

protected java.lang.String createName()
Specified by:
createName in class NetworkConnector


Copyright © 2009 Apache Software Foundation. All Rights Reserved.