org.apache.activemq.network
Class MulticastNetworkConnector
java.lang.Object
org.apache.activemq.util.ServiceSupport
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.
- Version:
- $Revision: 426366 $
Methods inherited from class org.apache.activemq.network.NetworkConnector |
addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, getBrokerName, getConnectionFilter, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalUri, getName, getNetworkTTL, getPassword, getPrefetchSize, getStaticallyIncludedDestinations, getUserName, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDynamicOnly, setBridgeTempDestinations, setBrokerName, setConduitSubscriptions, setConnectionFilter, setDecreaseNetworkConsumerPriority, setDispatchAsync, setDurableDestinations, setDynamicallyIncludedDestinations, setDynamicOnly, setExcludedDestinations, setLocalUri, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticallyIncludedDestinations, setUserName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MulticastNetworkConnector
public MulticastNetworkConnector()
MulticastNetworkConnector
public MulticastNetworkConnector(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 URI getRemoteURI()
setRemoteURI
public void setRemoteURI(URI remoteURI)
- Sets the remote transport URI to some group transport like
multicast://address:port
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class NetworkConnector
- Throws:
Exception
doStop
protected void doStop(ServiceStopper stopper)
throws Exception
- Overrides:
doStop
in class NetworkConnector
- Throws:
Exception
createName
protected String createName()
- Specified by:
createName
in class NetworkConnector
createBridge
protected DemandForwardingBridgeSupport createBridge(Transport local,
Transport remote)
Copyright © 2011 Apache Software Foundation. All Rights Reserved.