org.codehaus.activemq.transport
Class DiscoveryTransportChannel
java.lang.Object
org.codehaus.activemq.transport.TransportChannelSupport
org.codehaus.activemq.transport.composite.CompositeTransportChannel
org.codehaus.activemq.transport.reliable.ReliableTransportChannel
org.codehaus.activemq.transport.DiscoveryTransportChannel
- All Implemented Interfaces:
- DiscoveryListener, ExceptionListener, PacketListener, Service, TransportChannel
- 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 $
Methods inherited from class org.codehaus.activemq.transport.composite.CompositeTransportChannel |
attemptToConnect, canProcessWireFormatVersion, establishConnection, getChannel, getCurrentWireFormatVersion, getEstablishConnectionTimeout, getFailureSleepTime, getMaximumRetries, getUris, isMulticast, send, setEstablishConnectionTimeout, setExceptionListener, setFailureSleepTime, setMaximumRetries, setPacketListener, setUris |
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getExceptionListener, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, setClientID, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, stopExecutor |
DiscoveryTransportChannel
public DiscoveryTransportChannel(WireFormat wireFormat,
DiscoveryAgent discoveryAgent)
start
public void start()
throws JMSException
- Description copied from class:
ReliableTransportChannel
- start the connection
- Specified by:
start
in interface TransportChannel
- Overrides:
start
in class ReliableTransportChannel
- 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)
- Specified by:
addService
in interface DiscoveryListener
removeService
public void removeService(DiscoveryEvent event)
- Specified by:
removeService
in interface DiscoveryListener
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 Protique, Ltd.. All Rights Reserved.