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 logical
Transport
instance such as when using multicast.
This implementation does not depend on multicast at all; any other group
based transport could be used.
Methods inherited from class org.apache.activemq.network.NetworkConnector |
activeBridges, addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, createNetworkBridgeObjectName, getBrokerService, getConnectionFilter, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalUri, getObjectName, getStaticallyIncludedDestinations, isStarted, isStopped, isStopping, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setLocalUri, setObjectName, setStaticallyIncludedDestinations, start, stop, unregisterNetworkBridgeMBean |
Methods inherited from class org.apache.activemq.network.NetworkBridgeConfiguration |
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
MulticastNetworkConnector
public MulticastNetworkConnector()
MulticastNetworkConnector
public MulticastNetworkConnector(java.net.URI remoteURI)
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 java.net.URI getRemoteURI()
setRemoteURI
public void setRemoteURI(java.net.URI remoteURI)
- Sets the remote transport URI to some group transport like
multicast://address:port
handleStart
protected void handleStart()
throws java.lang.Exception
- Overrides:
handleStart
in class NetworkConnector
- Throws:
java.lang.Exception
handleStop
protected void handleStop(ServiceStopper stopper)
throws java.lang.Exception
- Overrides:
handleStop
in class NetworkConnector
- Throws:
java.lang.Exception
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
createBridge
protected DemandForwardingBridgeSupport createBridge(Transport local,
Transport remote)
Copyright © 2005-2015. All Rights Reserved.