org.apache.activemq.network
public abstract class NetworkConnector extends NetworkBridgeConfiguration implements Service
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ConcurrentHashMap<java.net.URI,NetworkBridge> |
bridges |
protected ConnectionFilter |
connectionFilter |
protected java.net.URI |
localURI |
protected ServiceSupport |
serviceSupport |
Constructor and Description |
---|
NetworkConnector() |
NetworkConnector(java.net.URI localURI) |
getBrokerName, getBrokerURL, getConsumerPriorityBase, getDestinationFilter, getName, getNetworkTTL, getPassword, getPrefetchSize, getUserName, isAlwaysSyncSend, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setConduitSubscriptions, setConsumerPriorityBase, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setUserName
protected java.net.URI localURI
protected ConnectionFilter connectionFilter
protected java.util.concurrent.ConcurrentHashMap<java.net.URI,NetworkBridge> bridges
protected ServiceSupport serviceSupport
public NetworkConnector()
public NetworkConnector(java.net.URI localURI)
public java.net.URI getLocalUri() throws java.net.URISyntaxException
java.net.URISyntaxException
public void setLocalUri(java.net.URI localURI)
public java.util.Set getDurableDestinations()
public void setDurableDestinations(java.util.Set<ActiveMQDestination> durableDestinations)
durableDestinations
- The durableDestinations to set.public java.util.List<ActiveMQDestination> getExcludedDestinations()
getExcludedDestinations
in class NetworkBridgeConfiguration
public void setExcludedDestinations(java.util.List<ActiveMQDestination> excludedDestinations)
setExcludedDestinations
in class NetworkBridgeConfiguration
excludedDestinations
- The excludedDestinations to set.public void addExcludedDestination(ActiveMQDestination destiantion)
public java.util.List<ActiveMQDestination> getStaticallyIncludedDestinations()
getStaticallyIncludedDestinations
in class NetworkBridgeConfiguration
public void setStaticallyIncludedDestinations(java.util.List<ActiveMQDestination> staticallyIncludedDestinations)
setStaticallyIncludedDestinations
in class NetworkBridgeConfiguration
staticallyIncludedDestinations
- The staticallyIncludedDestinations
to set.public void addStaticallyIncludedDestination(ActiveMQDestination destiantion)
public java.util.List<ActiveMQDestination> getDynamicallyIncludedDestinations()
getDynamicallyIncludedDestinations
in class NetworkBridgeConfiguration
public void setDynamicallyIncludedDestinations(java.util.List<ActiveMQDestination> dynamicallyIncludedDestinations)
setDynamicallyIncludedDestinations
in class NetworkBridgeConfiguration
dynamicallyIncludedDestinations
- The
dynamicallyIncludedDestinations to set.public void addDynamicallyIncludedDestination(ActiveMQDestination destiantion)
public ConnectionFilter getConnectionFilter()
public void setConnectionFilter(ConnectionFilter connectionFilter)
protected NetworkBridge configureBridge(DemandForwardingBridgeSupport result)
protected Transport createLocalTransport() throws java.lang.Exception
java.lang.Exception
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
protected void handleStart() throws java.lang.Exception
java.lang.Exception
protected void handleStop(ServiceStopper stopper) throws java.lang.Exception
java.lang.Exception
public boolean isStarted()
public boolean isStopped()
public boolean isStopping()
public javax.management.ObjectName getObjectName()
public void setObjectName(javax.management.ObjectName objectName)
public BrokerService getBrokerService()
public void setBrokerService(BrokerService brokerService)
protected void registerNetworkBridgeMBean(NetworkBridge bridge)
protected void unregisterNetworkBridgeMBean(NetworkBridge bridge)
protected javax.management.ObjectName createNetworkBridgeObjectName(NetworkBridge bridge) throws javax.management.MalformedObjectNameException
javax.management.MalformedObjectNameException
public boolean removeDemandSubscription(ConsumerId consumerId)
public java.util.Collection<NetworkBridge> activeBridges()
Copyright © 2005-2014. All Rights Reserved.