org.apache.activemq.network
Class MulticastNetworkConnector

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      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.

Version:
$Revision: 426366 $

Field Summary
 
Fields inherited from class org.apache.activemq.network.NetworkConnector
conduitSubscriptions, connectionFilter, dynamicOnly, failover, localURI, log
 
Constructor Summary
MulticastNetworkConnector()
           
MulticastNetworkConnector(java.net.URI remoteURI)
           
 
Method Summary
protected  DemandForwardingBridgeSupport createBridge(Transport local, Transport remote)
           
protected  java.lang.String createName()
           
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
 DemandForwardingBridgeSupport getBridge()
           
 Transport getLocalTransport()
           
 Transport getRemoteTransport()
           
 java.net.URI getRemoteURI()
           
 void setBridge(DemandForwardingBridgeSupport bridge)
           
 void setLocalTransport(Transport localTransport)
           
 void setRemoteTransport(Transport remoteTransport)
          Sets the remote transport implementation
 void setRemoteURI(java.net.URI remoteURI)
          Sets the remote transport URI to some group transport like multicast://address:port
 
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 org.apache.activemq.util.ServiceSupport
dispose, isStarted, isStopped, isStopping, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MulticastNetworkConnector

public MulticastNetworkConnector()

MulticastNetworkConnector

public MulticastNetworkConnector(java.net.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 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


doStart

protected void doStart()
                throws java.lang.Exception
Overrides:
doStart in class NetworkConnector
Throws:
java.lang.Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception
Overrides:
doStop in class NetworkConnector
Throws:
java.lang.Exception

createName

protected java.lang.String createName()
Specified by:
createName in class NetworkConnector

createBridge

protected DemandForwardingBridgeSupport createBridge(Transport local,
                                                     Transport remote)


Copyright © 2010 Apache Software Foundation. All Rights Reserved.