Class DiscoveryNetworkConnector

java.lang.Object

org.apache.activemq.network.NetworkBridgeConfiguration

org.apache.activemq.network.NetworkConnector

org.apache.activemq.network.DiscoveryNetworkConnector

All Implemented Interfaces:

org.apache.activemq.Service, org.apache.activemq.transport.discovery.DiscoveryListener

public class DiscoveryNetworkConnector
extends NetworkConnector
implements org.apache.activemq.transport.discovery.DiscoveryListener

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

Field Summary

Fields inherited from class NetworkConnector

bridgeExceptionCounter, bridges, connectionFilter, localURI, networkBridgeStatistics, serviceSupport, startedTimestamp, stoppedTimestamp

Fields inherited from class NetworkBridgeConfiguration

DURABLE_SUB_PREFIX, dynamicallyIncludedDestinations, excludedDestinations, staticallyIncludedDestinations

Fields inherited from interface org.apache.activemq.transport.discovery.DiscoveryListener

DISCOVERED_OPTION_PREFIX

Constructor Summary

Constructors

Constructor	Description
DiscoveryNetworkConnector()
DiscoveryNetworkConnector(URI discoveryURI)

Method Summary

Modifier and Type	Method	Description
protected NetworkBridge	createBridge(org.apache.activemq.transport.Transport localTransport, org.apache.activemq.transport.Transport remoteTransport, org.apache.activemq.command.DiscoveryEvent event)
org.apache.activemq.transport.discovery.DiscoveryAgent	getDiscoveryAgent()
URI	getUri()
protected void	handleStart()
protected void	handleStop(org.apache.activemq.util.ServiceStopper stopper)
void	onServiceAdd(org.apache.activemq.command.DiscoveryEvent event)
void	onServiceRemove(org.apache.activemq.command.DiscoveryEvent event)
void	setDiscoveryAgent(org.apache.activemq.transport.discovery.DiscoveryAgent discoveryAgent)
void	setUri(URI discoveryURI)
String	toString()

Methods inherited from class NetworkConnector

activeBridges, addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, createNetworkBridgeObjectName, getBridgeExceptionCounter, getBrokerService, getConnectionFilter, getDurableDestinations, getDurableTopicDestinations, getLocalExceptionCounter, getLocalUri, getNetworkBridgeStatistics, getObjectName, getRemoteExceptionCounter, getStartedTimestamp, getStoppedTimestamp, isStarted, isStopped, isStopping, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setLocalUri, setObjectName, start, stop, unregisterNetworkBridgeMBean

Methods inherited from class NetworkBridgeConfiguration

getAdvisoryAckPercentage, getAdvisoryPrefetchSize, getBridgeFactory, getBrokerName, getBrokerURL, getClientIdToken, getConsumerPriorityBase, getConsumerTTL, getDestinationFilter, getDynamicallyIncludedDestinations, getExcludedDestinations, getGcSweepTime, getMessageTTL, getName, getNetworkTTL, getPassword, getPrefetchSize, getRemotePassword, getRemoteUserName, getSslContext, getStaticallyIncludedDestinations, getUserName, isAdvisoryForFailedForward, isAlwaysSyncSend, isAutoStart, isBridgeTempDestinations, isCheckDuplicateMessagesOnDuplex, isConduitNetworkQueueSubscriptions, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isGcDestinationViews, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, isSyncDurableSubs, isUseBrokerNamesAsIdSeed, isUseCompression, isUseVirtualDestSubs, setAdvisoryAckPercentage, setAdvisoryForFailedForward, setAdvisoryPrefetchSize, setAlwaysSyncSend, setAutoStart, setBridgeFactory, setBridgeTempDestinations, setBrokerName, setBrokerURL, setCheckDuplicateMessagesOnDuplex, setClientIdToken, setConduitNetworkQueueSubscriptions, setConduitSubscriptions, setConsumerPriorityBase, setConsumerTTL, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setGcDestinationViews, setGcSweepTime, setMessageTTL, setName, setNetworkTTL, setPassword, setPrefetchSize, setRemotePassword, setRemoteUserName, setSslContext, setStaticallyIncludedDestinations, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setSyncDurableSubs, setUseBrokerNameAsIdSees, setUseCompression, setUserName, setUseVirtualDestSubs

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DiscoveryNetworkConnector

public DiscoveryNetworkConnector()

DiscoveryNetworkConnector

public DiscoveryNetworkConnector(URI discoveryURI)
                          throws IOException

Throws:

IOException

Method Details

setUri

public void setUri(URI discoveryURI)
            throws IOException

Throws:

IOException

getUri

public URI getUri()

Specified by:

getUri in class NetworkConnector

onServiceAdd

public void onServiceAdd(org.apache.activemq.command.DiscoveryEvent event)

Specified by:

onServiceAdd in interface org.apache.activemq.transport.discovery.DiscoveryListener

onServiceRemove

public void onServiceRemove(org.apache.activemq.command.DiscoveryEvent event)

Specified by:

onServiceRemove in interface org.apache.activemq.transport.discovery.DiscoveryListener

getDiscoveryAgent

public org.apache.activemq.transport.discovery.DiscoveryAgent getDiscoveryAgent()

setDiscoveryAgent

public void setDiscoveryAgent(org.apache.activemq.transport.discovery.DiscoveryAgent discoveryAgent)

handleStart

protected void handleStart()
                    throws Exception

Overrides:

handleStart in class NetworkConnector

Throws:

Exception

handleStop

protected void handleStop(org.apache.activemq.util.ServiceStopper stopper)
                   throws Exception

Overrides:

handleStop in class NetworkConnector

Throws:

Exception

createBridge

protected NetworkBridge createBridge(org.apache.activemq.transport.Transport localTransport,
 org.apache.activemq.transport.Transport remoteTransport,
 org.apache.activemq.command.DiscoveryEvent event)

toString

public String toString()

Overrides:

toString in class Object