public abstract class NetworkConnector extends NetworkBridgeConfiguration implements Service
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<URI,NetworkBridge> |
bridges |
protected ConnectionFilter |
connectionFilter |
protected URI |
localURI |
protected ServiceSupport |
serviceSupport |
dynamicallyIncludedDestinations, excludedDestinations, staticallyIncludedDestinations
Constructor and Description |
---|
NetworkConnector() |
NetworkConnector(URI localURI) |
getAdvisoryAckPercentage, getAdvisoryPrefetchSize, getBrokerName, getBrokerURL, getConsumerPriorityBase, getConsumerTTL, getDestinationFilter, getDynamicallyIncludedDestinations, getExcludedDestinations, getGcSweepTime, getMessageTTL, getName, getNetworkTTL, getPassword, getPrefetchSize, getStaticallyIncludedDestinations, getUserName, isAdvisoryForFailedForward, isAlwaysSyncSend, isBridgeTempDestinations, isCheckDuplicateMessagesOnDuplex, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isGcDestinationViews, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, isSyncDurableSubs, isUseBrokerNamesAsIdSeed, isUseCompression, isUseVirtualDestSubs, isUseVirtualDestSus, setAdvisoryAckPercentage, setAdvisoryForFailedForward, setAdvisoryPrefetchSize, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setCheckDuplicateMessagesOnDuplex, setConduitSubscriptions, setConsumerPriorityBase, setConsumerTTL, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setGcDestinationViews, setGcSweepTime, setMessageTTL, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticallyIncludedDestinations, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setSyncDurableSubs, setUseBrokerNameAsIdSees, setUseCompression, setUserName, setUseVirtualDestSubs
protected ConnectionFilter connectionFilter
protected ConcurrentMap<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<ActiveMQDestination> getDurableDestinations()
public void setDurableDestinations(Set<ActiveMQDestination> durableDestinations)
durableDestinations
- The durableDestinations to set.public void addExcludedDestination(ActiveMQDestination destiantion)
public void addStaticallyIncludedDestination(ActiveMQDestination destiantion)
public void addDynamicallyIncludedDestination(ActiveMQDestination destiantion)
public ConnectionFilter getConnectionFilter()
public void setConnectionFilter(ConnectionFilter connectionFilter)
protected NetworkBridge configureBridge(DemandForwardingBridgeSupport result)
protected Transport createLocalTransport() throws Exception
Exception
public static ActiveMQDestination[] getDurableTopicDestinations(Set<ActiveMQDestination> durableDestinations)
protected void handleStart() throws Exception
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–2024 The Apache Software Foundation. All rights reserved.