org.apache.activemq.network
Class NetworkConnector
java.lang.Object
org.apache.activemq.network.NetworkBridgeConfiguration
org.apache.activemq.network.NetworkConnector
- All Implemented Interfaces:
- Service
- Direct Known Subclasses:
- DiscoveryNetworkConnector, LdapNetworkConnector, MulticastNetworkConnector
public abstract class NetworkConnector
- extends NetworkBridgeConfiguration
- implements Service
Methods inherited from class org.apache.activemq.network.NetworkBridgeConfiguration |
getBrokerName, getBrokerURL, getDestinationFilter, getName, getNetworkTTL, getPassword, getPrefetchSize, getUserName, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, setBridgeTempDestinations, setBrokerName, setBrokerURL, setConduitSubscriptions, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setUserName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
localURI
protected java.net.URI localURI
connectionFilter
protected ConnectionFilter connectionFilter
bridges
protected java.util.concurrent.ConcurrentHashMap<java.net.URI,NetworkBridge> bridges
serviceSupport
protected ServiceSupport serviceSupport
NetworkConnector
public NetworkConnector()
NetworkConnector
public NetworkConnector(java.net.URI localURI)
getLocalUri
public java.net.URI getLocalUri()
throws java.net.URISyntaxException
- Throws:
java.net.URISyntaxException
setLocalUri
public void setLocalUri(java.net.URI localURI)
getDurableDestinations
public java.util.Set getDurableDestinations()
- Returns:
- Returns the durableDestinations.
setDurableDestinations
public void setDurableDestinations(java.util.Set<ActiveMQDestination> durableDestinations)
- Parameters:
durableDestinations
- The durableDestinations to set.
getExcludedDestinations
public java.util.List<ActiveMQDestination> getExcludedDestinations()
- Overrides:
getExcludedDestinations
in class NetworkBridgeConfiguration
- Returns:
- Returns the excludedDestinations.
setExcludedDestinations
public void setExcludedDestinations(java.util.List<ActiveMQDestination> excludedDestinations)
- Overrides:
setExcludedDestinations
in class NetworkBridgeConfiguration
- Parameters:
excludedDestinations
- The excludedDestinations to set.
addExcludedDestination
public void addExcludedDestination(ActiveMQDestination destiantion)
getStaticallyIncludedDestinations
public java.util.List<ActiveMQDestination> getStaticallyIncludedDestinations()
- Overrides:
getStaticallyIncludedDestinations
in class NetworkBridgeConfiguration
- Returns:
- Returns the staticallyIncludedDestinations.
setStaticallyIncludedDestinations
public void setStaticallyIncludedDestinations(java.util.List<ActiveMQDestination> staticallyIncludedDestinations)
- Overrides:
setStaticallyIncludedDestinations
in class NetworkBridgeConfiguration
- Parameters:
staticallyIncludedDestinations
- The staticallyIncludedDestinations
to set.
addStaticallyIncludedDestination
public void addStaticallyIncludedDestination(ActiveMQDestination destiantion)
getDynamicallyIncludedDestinations
public java.util.List<ActiveMQDestination> getDynamicallyIncludedDestinations()
- Overrides:
getDynamicallyIncludedDestinations
in class NetworkBridgeConfiguration
- Returns:
- Returns the dynamicallyIncludedDestinations.
setDynamicallyIncludedDestinations
public void setDynamicallyIncludedDestinations(java.util.List<ActiveMQDestination> dynamicallyIncludedDestinations)
- Overrides:
setDynamicallyIncludedDestinations
in class NetworkBridgeConfiguration
- Parameters:
dynamicallyIncludedDestinations
- The
dynamicallyIncludedDestinations to set.
addDynamicallyIncludedDestination
public void addDynamicallyIncludedDestination(ActiveMQDestination destiantion)
getConnectionFilter
public ConnectionFilter getConnectionFilter()
setConnectionFilter
public void setConnectionFilter(ConnectionFilter connectionFilter)
configureBridge
protected NetworkBridge configureBridge(DemandForwardingBridgeSupport result)
createLocalTransport
protected Transport createLocalTransport()
throws java.lang.Exception
- Throws:
java.lang.Exception
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface Service
- Throws:
java.lang.Exception
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Throws:
java.lang.Exception
handleStart
protected void handleStart()
throws java.lang.Exception
- Throws:
java.lang.Exception
handleStop
protected void handleStop(ServiceStopper stopper)
throws java.lang.Exception
- Throws:
java.lang.Exception
getObjectName
public javax.management.ObjectName getObjectName()
setObjectName
public void setObjectName(javax.management.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 javax.management.ObjectName createNetworkBridgeObjectName(NetworkBridge bridge)
throws javax.management.MalformedObjectNameException
- Throws:
javax.management.MalformedObjectNameException
removeDemandSubscription
public boolean removeDemandSubscription(ConsumerId consumerId)
activeBridges
public java.util.Collection<NetworkBridge> activeBridges()
Copyright © 2005-2011. All Rights Reserved.