org.activemq.transport
Class DiscoveryTransportChannel
java.lang.Object
org.activemq.transport.TransportChannelSupport
org.activemq.transport.composite.CompositeTransportChannel
org.activemq.transport.reliable.ReliableTransportChannel
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 $
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 |
DiscoveryTransportChannel
public DiscoveryTransportChannel(WireFormat wireFormat,
DiscoveryAgent discoveryAgent)
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-2008 Protique, Ltd.. All Rights Reserved.