Class NetworkConnector

java.lang.Object

org.apache.activemq.network.NetworkBridgeConfiguration

org.apache.activemq.network.NetworkConnector

All Implemented Interfaces:

org.apache.activemq.Service

Direct Known Subclasses:

DiscoveryNetworkConnector, LdapNetworkConnector, MulticastNetworkConnector

public abstract class NetworkConnector
extends NetworkBridgeConfiguration
implements org.apache.activemq.Service

Connector class for bridging broker networks.

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.activemq.management.CountStatisticImpl	bridgeExceptionCounter
protected ConcurrentMap<URI, NetworkBridge>	bridges
protected ConnectionFilter	connectionFilter
protected URI	localURI
protected final NetworkBridgeStatistics	networkBridgeStatistics
protected org.apache.activemq.util.ServiceSupport	serviceSupport
protected final AtomicLong	startedTimestamp
protected final AtomicLong	stoppedTimestamp

Fields inherited from class NetworkBridgeConfiguration

DURABLE_SUB_PREFIX, dynamicallyIncludedDestinations, excludedDestinations, staticallyIncludedDestinations

Constructor Summary

Constructors

Constructor	Description
NetworkConnector()
NetworkConnector(URI localURI)

Method Summary

Modifier and Type	Method	Description
Collection<NetworkBridge>	activeBridges()
void	addDynamicallyIncludedDestination(org.apache.activemq.command.ActiveMQDestination destination)
void	addExcludedDestination(org.apache.activemq.command.ActiveMQDestination destination)
void	addStaticallyIncludedDestination(org.apache.activemq.command.ActiveMQDestination destination)
protected NetworkBridge	configureBridge(DemandForwardingBridgeSupport result)
protected org.apache.activemq.transport.Transport	createLocalTransport()
protected ObjectName	createNetworkBridgeObjectName(NetworkBridge bridge)
org.apache.activemq.management.CountStatistic	getBridgeExceptionCounter()
BrokerService	getBrokerService()
ConnectionFilter	getConnectionFilter()
Set<org.apache.activemq.command.ActiveMQDestination>	getDurableDestinations()
static org.apache.activemq.command.ActiveMQDestination[]	getDurableTopicDestinations(Set<org.apache.activemq.command.ActiveMQDestination> durableDestinations)
org.apache.activemq.management.CountStatistic	getLocalExceptionCounter()
URI	getLocalUri()
NetworkBridgeStatistics	getNetworkBridgeStatistics()
ObjectName	getObjectName()
org.apache.activemq.management.CountStatistic	getRemoteExceptionCounter()
long	getStartedTimestamp()
long	getStoppedTimestamp()
abstract URI	getUri()
protected void	handleStart()
protected void	handleStop(org.apache.activemq.util.ServiceStopper stopper)
boolean	isStarted()
boolean	isStopped()
boolean	isStopping()
protected void	registerNetworkBridgeMBean(NetworkBridge bridge)
boolean	removeDemandSubscription(org.apache.activemq.command.ConsumerId consumerId)
void	setBrokerService(BrokerService brokerService)
void	setConnectionFilter(ConnectionFilter connectionFilter)
void	setDurableDestinations(Set<org.apache.activemq.command.ActiveMQDestination> durableDestinations)
void	setLocalUri(URI localURI)
void	setObjectName(ObjectName objectName)
void	start()
void	stop()
protected void	unregisterNetworkBridgeMBean(NetworkBridge bridge)

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, toString, wait, wait, wait

Field Details

localURI

protected URI localURI

connectionFilter

protected ConnectionFilter connectionFilter

bridges

protected ConcurrentMap<URI, NetworkBridge> bridges

startedTimestamp

protected final AtomicLong startedTimestamp

stoppedTimestamp

protected final AtomicLong stoppedTimestamp

bridgeExceptionCounter

protected final org.apache.activemq.management.CountStatisticImpl bridgeExceptionCounter

networkBridgeStatistics

protected final NetworkBridgeStatistics networkBridgeStatistics

serviceSupport

protected org.apache.activemq.util.ServiceSupport serviceSupport

Constructor Details

NetworkConnector

public NetworkConnector()

NetworkConnector

public NetworkConnector(URI localURI)

Method Details

getUri

public abstract URI getUri()

getLocalUri

public URI getLocalUri()
                throws URISyntaxException

Throws:

URISyntaxException

setLocalUri

public void setLocalUri(URI localURI)

getDurableDestinations

public Set<org.apache.activemq.command.ActiveMQDestination> getDurableDestinations()

Returns:

Returns the durableDestinations.

setDurableDestinations

public void setDurableDestinations(Set<org.apache.activemq.command.ActiveMQDestination> durableDestinations)

Parameters:

durableDestinations - The durableDestinations to set.

addExcludedDestination

public void addExcludedDestination(org.apache.activemq.command.ActiveMQDestination destination)

addStaticallyIncludedDestination

public void addStaticallyIncludedDestination(org.apache.activemq.command.ActiveMQDestination destination)

addDynamicallyIncludedDestination

public void addDynamicallyIncludedDestination(org.apache.activemq.command.ActiveMQDestination destination)

getConnectionFilter

public ConnectionFilter getConnectionFilter()

setConnectionFilter

public void setConnectionFilter(ConnectionFilter connectionFilter)

configureBridge

protected NetworkBridge configureBridge(DemandForwardingBridgeSupport result)

createLocalTransport

protected org.apache.activemq.transport.Transport createLocalTransport()
                                                                throws Exception

Throws:

Exception

getDurableTopicDestinations

public static org.apache.activemq.command.ActiveMQDestination[] getDurableTopicDestinations(Set<org.apache.activemq.command.ActiveMQDestination> durableDestinations)

start

public void start()
           throws Exception

Specified by:

start in interface org.apache.activemq.Service

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface org.apache.activemq.Service

Throws:

Exception

handleStart

protected void handleStart()
                    throws Exception

Throws:

Exception

handleStop

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

Throws:

Exception

isStarted

public boolean isStarted()

isStopped

public boolean isStopped()

isStopping

public boolean isStopping()

getObjectName

public ObjectName getObjectName()

setObjectName

public void setObjectName(ObjectName objectName)

getBrokerService

public BrokerService getBrokerService()

setBrokerService

public void setBrokerService(BrokerService brokerService)

registerNetworkBridgeMBean

protected void registerNetworkBridgeMBean(NetworkBridge bridge)

unregisterNetworkBridgeMBean

protected void unregisterNetworkBridgeMBean(NetworkBridge bridge)

createNetworkBridgeObjectName

protected ObjectName createNetworkBridgeObjectName(NetworkBridge bridge)
                                            throws MalformedObjectNameException

Throws:

MalformedObjectNameException

removeDemandSubscription

public boolean removeDemandSubscription(org.apache.activemq.command.ConsumerId consumerId)

activeBridges

public Collection<NetworkBridge> activeBridges()

getStartedTimestamp

public long getStartedTimestamp()

getStoppedTimestamp

public long getStoppedTimestamp()

getBridgeExceptionCounter

public org.apache.activemq.management.CountStatistic getBridgeExceptionCounter()

getLocalExceptionCounter

public org.apache.activemq.management.CountStatistic getLocalExceptionCounter()

getRemoteExceptionCounter

public org.apache.activemq.management.CountStatistic getRemoteExceptionCounter()

getNetworkBridgeStatistics

public NetworkBridgeStatistics getNetworkBridgeStatistics()

Returns:

the connector-level statistics that aggregate every bridge's statistics. A bridge sets this as the parent of its own NetworkBridgeStatistics so the counts roll up automatically.