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.
- Version:
- $Revision: 725323 $
Methods inherited from class org.apache.activemq.network.NetworkConnector |
activeBridges, addDynamicallyIncludedDestination, addExcludedDestination, addStaticallyIncludedDestination, configureBridge, createLocalTransport, createNetworkBridgeObjectName, getBrokerService, getConnectionFilter, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalUri, getObjectName, getStaticallyIncludedDestinations, registerNetworkBridgeMBean, removeDemandSubscription, setBrokerService, setConnectionFilter, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setLocalUri, setObjectName, setStaticallyIncludedDestinations, start, stop, unregisterNetworkBridgeMBean |
Methods inherited from class org.apache.activemq.network.NetworkBridgeConfiguration |
getBrokerName, getDestinationFilter, getNetworkTTL, getPassword, getPrefetchSize, getUserName, isBridgeTempDestinations, isConduitSubscriptions, isDecreaseNetworkConsumerPriority, isDispatchAsync, isDuplex, isDynamicOnly, isSuppressDuplicateQueueSubscriptions, setBridgeTempDestinations, setBrokerName, setConduitSubscriptions, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setSuppressDuplicateQueueSubscriptions, 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
handleStart
protected void handleStart()
throws Exception
- Overrides:
handleStart
in class NetworkConnector
- Throws:
Exception
handleStop
protected void handleStop(ServiceStopper stopper)
throws Exception
- Overrides:
handleStop
in class NetworkConnector
- Throws:
Exception
getName
public String getName()
- Overrides:
getName
in class NetworkBridgeConfiguration
- Returns:
- the name
createBridge
protected DemandForwardingBridgeSupport createBridge(Transport local,
Transport remote)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.