org.codehaus.activemq.transport
Class DiscoveryTransportChannel

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportChannelSupport
      extended byorg.codehaus.activemq.transport.composite.CompositeTransportChannel
          extended byorg.codehaus.activemq.transport.reliable.ReliableTransportChannel
              extended byorg.codehaus.activemq.transport.DiscoveryTransportChannel
All Implemented Interfaces:
DiscoveryListener, ExceptionListener, PacketListener, Service, 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.3 $

Field Summary
 
Fields inherited from class org.codehaus.activemq.transport.composite.CompositeTransportChannel
channel, closed, currentURI, failureSleepTime, maximumRetries, started, uris, wireFormat
 
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport
pendingStop, transportConnected
 
Constructor Summary
DiscoveryTransportChannel(WireFormat wireFormat, DiscoveryAgent discoveryAgent)
           
 
Method Summary
 void addService(DiscoveryEvent event)
          A service has started
 DiscoveryAgent getDiscoveryAgent()
           
 String getRemotePassword()
           
 String getRemoteUserName()
           
 void removeService(DiscoveryEvent event)
          A service has stopped
 void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
           
 void setRemotePassword(String remotePassword)
           
 void setRemoteUserName(String remoteUserName)
           
 void start()
          start listeneing for events
 void stop()
          stop this channel
 
Methods inherited from class org.codehaus.activemq.transport.reliable.ReliableTransportChannel
asyncSend, asyncSendWithReceipt, configureChannel, consume, doReconnect, extractURI, fireException, getEstablishedChannel, getKeepAliveTimeout, onException, send, setKeepAliveTimeout, toString
 
Methods inherited from class org.codehaus.activemq.transport.composite.CompositeTransportChannel
attemptToConnect, canProcessWireFormatVersion, establishConnection, forceDisconnect, getChannel, getCurrentWireFormatVersion, getEstablishConnectionTimeout, getFailureSleepTime, getLastReceiptTimestamp, getMaximumRetries, getUris, isMulticast, isTransportConnected, send, setEstablishConnectionTimeout, setExceptionListener, setFailureSleepTime, setMaximumRetries, setPacketListener, setUris, statusChanged
 
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport
addTransportStatusEventListener, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, setClientID, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, 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: TransportChannel
start listeneing for events

Specified by:
start in interface TransportChannel
Overrides:
start in class CompositeTransportChannel
Throws:
JMSException

stop

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

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
Parameters:
event -

removeService

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

Specified by:
removeService in interface DiscoveryListener
Parameters:
event -

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-2005 Protique, Ltd.. All Rights Reserved.