org.activemq.transport
Class DiscoveryTransportChannel

java.lang.Object
  extended by org.activemq.transport.TransportChannelSupport
      extended by org.activemq.transport.composite.CompositeTransportChannel
          extended by org.activemq.transport.reliable.ReliableTransportChannel
              extended by org.activemq.transport.DiscoveryTransportChannel
All Implemented Interfaces:
ExceptionListener, PacketListener, Service, DiscoveryListener, TransportChannel, TransportStatusEventListener

public class DiscoveryTransportChannel
extends ReliableTransportChannel
implements DiscoveryListener

A ReliableTransportChannel which uses a DiscoveryAgent to discover remote broker instances and dynamically connect to them.

Version:
$Revision: 1.1.1.1 $

Field Summary
 
Fields inherited from class org.activemq.transport.composite.CompositeTransportChannel
channel, closed, currentURI, establishConnectionTimeout, failureSleepTime, incrementTimeout, maximumRetries, maximumTimeout, started, uris
 
Fields inherited from class org.activemq.transport.TransportChannelSupport
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally
 
Constructor Summary
DiscoveryTransportChannel(WireFormat wireFormat, DiscoveryAgent discoveryAgent)
           
 
Method Summary
 void addService(DiscoveryEvent event)
          A service has started
protected  void addURI(URI uri, Map details)
           
 DiscoveryAgent getDiscoveryAgent()
           
 String getRemotePassword()
           
 String getRemoteUserName()
           
protected  List parseURIs(URI uri)
           
 void removeService(DiscoveryEvent event)
          A service has stopped
protected  void removeURI(URI uri)
           
 void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
           
 void setRemotePassword(String remotePassword)
           
 void setRemoteUserName(String remoteUserName)
           
 void start()
          Called to start the service
 void stop()
          stop this channel
 
Methods inherited from class org.activemq.transport.reliable.ReliableTransportChannel
asyncSend, asyncSendWithReceipt, configureChannel, consume, doClose, doReconnect, extractURI, fireException, getEstablishedChannel, getKeepAliveTimeout, onException, send, setKeepAliveTimeout, toString
 
Methods inherited from class org.activemq.transport.composite.CompositeTransportChannel
attemptToConnect, canProcessWireFormatVersion, establishConnection, forceDisconnect, getChannel, getCurrentWireFormatVersion, getEstablishConnectionTimeout, getFailureSleepTime, getLastReceiptTimestamp, getMaximumRetries, getMaximumTimeout, getUris, isIncrementTimeout, isMulticast, isTransportConnected, send, setClientID, setEstablishConnectionTimeout, setExceptionListener, setFailureSleepTime, setIncrementTimeout, setMaximumRetries, setMaximumTimeout, setPacketListener, setUris, statusChanged
 
Methods inherited from class org.activemq.transport.TransportChannelSupport
addTransportStatusEventListener, doAsyncSend, doConsumePacket, doConsumePacket, doesSupportMessageCompression, doesSupportMessageFragmentation, doesSupportWireFormatVersioning, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getPacketListener, getTransportChannelListener, getWireFormat, isCachingEnabled, isNoDelay, isPendingStop, isServerSide, isUsedInternally, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, setCachingEnabled, setNoDelay, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, setUsedInternally, setWireFormat, stopExecutor
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

DiscoveryTransportChannel

public DiscoveryTransportChannel(WireFormat wireFormat,
                                 DiscoveryAgent discoveryAgent)
Method Detail

start

public void start()
           throws JMSException
Description copied from interface: Service
Called to start the service

Specified by:
start in interface Service
Specified by:
start in interface TransportChannel
Overrides:
start in class CompositeTransportChannel
Throws:
JMSException - if an error occurs

stop

public void stop()
Description copied from class: ReliableTransportChannel
stop this channel

Specified by:
stop in interface Service
Specified by:
stop in interface TransportChannel
Overrides:
stop in class ReliableTransportChannel

addService

public void addService(DiscoveryEvent event)
Description copied from interface: DiscoveryListener
A service has started

Specified by:
addService in interface DiscoveryListener

removeService

public void removeService(DiscoveryEvent event)
Description copied from interface: DiscoveryListener
A service has stopped

Specified by:
removeService in interface DiscoveryListener

addURI

protected void addURI(URI uri,
                      Map details)

removeURI

protected void removeURI(URI uri)

parseURIs

protected List parseURIs(URI uri)

getDiscoveryAgent

public DiscoveryAgent getDiscoveryAgent()

setDiscoveryAgent

public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)

getRemotePassword

public String getRemotePassword()

setRemotePassword

public void setRemotePassword(String remotePassword)

getRemoteUserName

public String getRemoteUserName()

setRemoteUserName

public void setRemoteUserName(String remoteUserName)


Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.