org.apache.activemq.network
Class MulticastNetworkConnector

java.lang.Object
  extended by org.apache.activemq.network.NetworkBridgeConfiguration
      extended by org.apache.activemq.network.NetworkConnector
          extended by 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.


Field Summary
 
Fields inherited from class org.apache.activemq.network.NetworkConnector
bridges, connectionFilter, localURI, serviceSupport
 
Constructor Summary
MulticastNetworkConnector()
           
MulticastNetworkConnector(URI remoteURI)
           
 
Method Summary
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 implementation
 void setRemoteURI(URI remoteURI)
          Sets the remote transport URI to some group transport like multicast://address:port
 String toString()
           
 
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, isUseCompression, setAlwaysSyncSend, setBridgeTempDestinations, setBrokerName, setBrokerURL, setConduitSubscriptions, setConsumerPriorityBase, setDecreaseNetworkConsumerPriority, setDestinationFilter, setDispatchAsync, setDuplex, setDynamicOnly, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticBridge, setSuppressDuplicateQueueSubscriptions, setSuppressDuplicateTopicSubscriptions, setUseCompression, setUserName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

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 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

toString

public String toString()
Overrides:
toString in class Object

createBridge

protected DemandForwardingBridgeSupport createBridge(Transport local,
                                                     Transport remote)


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.