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, 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 $
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 |
DiscoveryTransportChannel
public DiscoveryTransportChannel(WireFormat wireFormat,
DiscoveryAgent discoveryAgent)
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.