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
- Version:
- $Revision$
Methods inherited from class org.apache.activemq.network.NetworkBridgeConfiguration |
getBrokerName, getDestinationFilter, getName, getNetworkTTL, getPassword, getPrefetchSize, getUserName, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isSuppressDuplicateQueueSubscriptions, setBridgeTempDestinations, setBrokerName, setConduitSubscriptions, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setSuppressDuplicateQueueSubscriptions, setUserName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
localURI
protected URI localURI
connectionFilter
protected ConnectionFilter connectionFilter
bridges
protected ConcurrentHashMap<URI,NetworkBridge> bridges
serviceSupport
protected ServiceSupport serviceSupport
NetworkConnector
public NetworkConnector()
NetworkConnector
public NetworkConnector(URI localURI)
getLocalUri
public URI getLocalUri()
throws URISyntaxException
- Throws:
URISyntaxException
setLocalUri
public void setLocalUri(URI localURI)
getDurableDestinations
public Set getDurableDestinations()
- Returns:
- Returns the durableDestinations.
setDurableDestinations
public void setDurableDestinations(Set<ActiveMQDestination> durableDestinations)
- Parameters:
durableDestinations
- The durableDestinations to set.
getExcludedDestinations
public List<ActiveMQDestination> getExcludedDestinations()
- Overrides:
getExcludedDestinations
in class NetworkBridgeConfiguration
- Returns:
- Returns the excludedDestinations.
setExcludedDestinations
public void setExcludedDestinations(List<ActiveMQDestination> excludedDestinations)
- Overrides:
setExcludedDestinations
in class NetworkBridgeConfiguration
- Parameters:
excludedDestinations
- The excludedDestinations to set.
addExcludedDestination
public void addExcludedDestination(ActiveMQDestination destiantion)
getStaticallyIncludedDestinations
public List<ActiveMQDestination> getStaticallyIncludedDestinations()
- Overrides:
getStaticallyIncludedDestinations
in class NetworkBridgeConfiguration
- Returns:
- Returns the staticallyIncludedDestinations.
setStaticallyIncludedDestinations
public void setStaticallyIncludedDestinations(List<ActiveMQDestination> staticallyIncludedDestinations)
- Overrides:
setStaticallyIncludedDestinations
in class NetworkBridgeConfiguration
- Parameters:
staticallyIncludedDestinations
- The staticallyIncludedDestinations
to set.
addStaticallyIncludedDestination
public void addStaticallyIncludedDestination(ActiveMQDestination destiantion)
getDynamicallyIncludedDestinations
public List<ActiveMQDestination> getDynamicallyIncludedDestinations()
- Overrides:
getDynamicallyIncludedDestinations
in class NetworkBridgeConfiguration
- Returns:
- Returns the dynamicallyIncludedDestinations.
setDynamicallyIncludedDestinations
public void setDynamicallyIncludedDestinations(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 Exception
- Throws:
Exception
start
public void start()
throws Exception
- Specified by:
start
in interface Service
- Throws:
Exception
stop
public void stop()
throws Exception
- Specified by:
stop
in interface Service
- Throws:
Exception
handleStart
protected void handleStart()
throws Exception
- Throws:
Exception
handleStop
protected void handleStop(ServiceStopper stopper)
throws Exception
- Throws:
Exception
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(ConsumerId consumerId)
activeBridges
public Collection<NetworkBridge> activeBridges()
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.