Package org.apache.activemq.network
Class MulticastNetworkConnector
- java.lang.Object
-
- org.apache.activemq.network.NetworkBridgeConfiguration
-
- org.apache.activemq.network.NetworkConnector
-
- org.apache.activemq.network.MulticastNetworkConnector
-
- All Implemented Interfaces:
Service
public class MulticastNetworkConnector extends NetworkConnector
A network connector which uses some kind of multicast-like transport that communicates with potentially many remote brokers over a single logicalTransport
instance such as when using multicast. This implementation does not depend on multicast at all; any other group based transport could be used.
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.network.NetworkConnector
bridges, connectionFilter, localURI, serviceSupport
-
Fields inherited from class org.apache.activemq.network.NetworkBridgeConfiguration
dynamicallyIncludedDestinations, excludedDestinations, staticallyIncludedDestinations
-
-
Constructor Summary
Constructors Constructor Description MulticastNetworkConnector()
MulticastNetworkConnector(URI remoteURI)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected DemandForwardingBridgeSupport
createBridge(Transport local, Transport remote)
DemandForwardingBridgeSupport
getBridge()
Transport
getLocalTransport()
Transport
getRemoteTransport()
URI
getRemoteURI()
protected void
handleStart()
protected void
handleStop(ServiceStopper stopper)
void
setBridge(DemandForwardingBridgeSupport bridge)
void
setLocalTransport(Transport localTransport)
void
setRemoteTransport(Transport remoteTransport)
Sets the remote transport implementationvoid
setRemoteURI(URI remoteURI)
Sets the remote transport URI to some group transport likemulticast://address:port
String
toString()
-
Methods inherited from class org.apache.activemq.network.NetworkConnector
activeBridges, addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, createNetworkBridgeObjectName, getBrokerService, getConnectionFilter, getDurableDestinations, getDurableTopicDestinations, getLocalUri, getObjectName, isStarted, isStopped, isStopping, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setLocalUri, setObjectName, start, stop, unregisterNetworkBridgeMBean
-
Methods inherited from class org.apache.activemq.network.NetworkBridgeConfiguration
getAdvisoryAckPercentage, getAdvisoryPrefetchSize, getBridgeFactory, getBrokerName, getBrokerURL, getClientIdToken, getConsumerPriorityBase, getConsumerTTL, getDestinationFilter, getDynamicallyIncludedDestinations, getExcludedDestinations, getGcSweepTime, getMessageTTL, getName, getNetworkTTL, getPassword, getPrefetchSize, getRemotePassword, getRemoteUserName, getSslContext, getStaticallyIncludedDestinations, getUserName, isAdvisoryForFailedForward, isAlwaysSyncSend, isBridgeTempDestinations, isCheckDuplicateMessagesOnDuplex, isConduitNetworkQueueSubscriptions, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isGcDestinationViews, isStaticBridge, isSuppressDuplicateQueueSubscriptions, isSuppressDuplicateTopicSubscriptions, isSyncDurableSubs, isUseBrokerNamesAsIdSeed, isUseCompression, isUseVirtualDestSubs, isUseVirtualDestSus, setAdvisoryAckPercentage, setAdvisoryForFailedForward, setAdvisoryPrefetchSize, setAlwaysSyncSend, setBridgeFactory, setBridgeTempDestinations, setBrokerName, setBrokerURL, setCheckDuplicateMessagesOnDuplex, setClientIdToken, setConduitNetworkQueueSubscriptions, setConduitSubscriptions, setConsumerPriorityBase, setConsumerTTL, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setGcDestinationViews, setGcSweepTime, setMessageTTL, setName, setNetworkTTL, setPassword, setPrefetchSize, setRemotePassword, setRemoteUserName, setSslContext, setStaticallyIncludedDestinations, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setSyncDurableSubs, setUseBrokerNameAsIdSees, setUseCompression, setUserName, setUseVirtualDestSubs
-
-
-
-
Constructor Detail
-
MulticastNetworkConnector
public MulticastNetworkConnector()
-
MulticastNetworkConnector
public MulticastNetworkConnector(URI remoteURI)
-
-
Method Detail
-
getBridge
public DemandForwardingBridgeSupport getBridge()
-
setBridge
public void setBridge(DemandForwardingBridgeSupport bridge)
-
getLocalTransport
public Transport getLocalTransport()
-
setLocalTransport
public void setLocalTransport(Transport localTransport)
-
getRemoteTransport
public Transport getRemoteTransport()
-
setRemoteTransport
public void setRemoteTransport(Transport remoteTransport)
Sets the remote transport implementation
-
getRemoteURI
public URI getRemoteURI()
-
setRemoteURI
public void setRemoteURI(URI remoteURI)
Sets the remote transport URI to some group transport likemulticast://address:port
-
handleStart
protected void handleStart() throws Exception
- Overrides:
handleStart
in classNetworkConnector
- Throws:
Exception
-
handleStop
protected void handleStop(ServiceStopper stopper) throws Exception
- Overrides:
handleStop
in classNetworkConnector
- Throws:
Exception
-
createBridge
protected DemandForwardingBridgeSupport createBridge(Transport local, Transport remote)
-
-