public abstract class NetworkConnector extends NetworkBridgeConfiguration implements Service
Modifier and Type | Field and Description |
---|---|
protected ConcurrentHashMap<URI,NetworkBridge> |
bridges |
protected ConnectionFilter |
connectionFilter |
protected URI |
localURI |
protected ServiceSupport |
serviceSupport |
Constructor and Description |
---|
NetworkConnector() |
NetworkConnector(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 URI localURI
protected ConnectionFilter connectionFilter
protected ConcurrentHashMap<URI,NetworkBridge> bridges
protected ServiceSupport serviceSupport
public NetworkConnector()
public NetworkConnector(URI localURI)
public URI getLocalUri() throws URISyntaxException
URISyntaxException
public void setLocalUri(URI localURI)
public Set getDurableDestinations()
public void setDurableDestinations(Set<ActiveMQDestination> durableDestinations)
durableDestinations
- The durableDestinations to set.public List<ActiveMQDestination> getExcludedDestinations()
getExcludedDestinations
in class NetworkBridgeConfiguration
public void setExcludedDestinations(List<ActiveMQDestination> excludedDestinations)
setExcludedDestinations
in class NetworkBridgeConfiguration
excludedDestinations
- The excludedDestinations to set.public void addExcludedDestination(ActiveMQDestination destiantion)
public List<ActiveMQDestination> getStaticallyIncludedDestinations()
getStaticallyIncludedDestinations
in class NetworkBridgeConfiguration
public void setStaticallyIncludedDestinations(List<ActiveMQDestination> staticallyIncludedDestinations)
setStaticallyIncludedDestinations
in class NetworkBridgeConfiguration
staticallyIncludedDestinations
- The staticallyIncludedDestinations
to set.public void addStaticallyIncludedDestination(ActiveMQDestination destiantion)
public List<ActiveMQDestination> getDynamicallyIncludedDestinations()
getDynamicallyIncludedDestinations
in class NetworkBridgeConfiguration
public void setDynamicallyIncludedDestinations(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)
public void start() throws Exception
protected void handleStop(ServiceStopper stopper) throws Exception
Exception
public boolean isStarted()
public boolean isStopped()
public boolean isStopping()
public ObjectName getObjectName()
public void setObjectName(ObjectName objectName)
public BrokerService getBrokerService()
public void setBrokerService(BrokerService brokerService)
protected void registerNetworkBridgeMBean(NetworkBridge bridge)
protected void unregisterNetworkBridgeMBean(NetworkBridge bridge)
protected ObjectName createNetworkBridgeObjectName(NetworkBridge bridge) throws MalformedObjectNameException
MalformedObjectNameException
public boolean removeDemandSubscription(ConsumerId consumerId)
public Collection<NetworkBridge> activeBridges()
Copyright © 2005–2014 The Apache Software Foundation. All rights reserved.