org.apache.activemq.transport.discovery

Class DiscoveryTransport

java.lang.Object

org.apache.activemq.transport.TransportFilter

org.apache.activemq.transport.discovery.DiscoveryTransport

All Implemented Interfaces:

Service, DiscoveryListener, Transport, TransportListener

public class DiscoveryTransport
extends TransportFilter
implements DiscoveryListener

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

Field Summary

Fields inherited from class org.apache.activemq.transport.TransportFilter

transportListener

Fields inherited from interface org.apache.activemq.transport.discovery.DiscoveryListener

DISCOVERED_OPTION_PREFIX

Constructor Summary

Constructors

Constructor and Description
DiscoveryTransport(CompositeTransport next)

Method Summary

Methods

Modifier and Type	Method and Description
DiscoveryAgent	getDiscoveryAgent()
void	onServiceAdd(DiscoveryEvent event)
void	onServiceRemove(DiscoveryEvent event)
void	setDiscoveryAgent(DiscoveryAgent discoveryAgent)
void	setParameters(Map<String,String> parameters)
void	start()
void	stop()

Methods inherited from class org.apache.activemq.transport.TransportFilter

asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onCommand, oneway, onException, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

DiscoveryTransport

public DiscoveryTransport(CompositeTransport next)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface Service

Overrides:

start in class TransportFilter

Throws:

Exception

See Also:

Service.start()

stop

public void stop()
          throws Exception

Specified by:

stop in interface Service

Overrides:

stop in class TransportFilter

Throws:

Exception

See Also:

Service.stop()

onServiceAdd

public void onServiceAdd(DiscoveryEvent event)

Specified by:

onServiceAdd in interface DiscoveryListener

onServiceRemove

public void onServiceRemove(DiscoveryEvent event)

Specified by:

onServiceRemove in interface DiscoveryListener

getDiscoveryAgent

public DiscoveryAgent getDiscoveryAgent()

setDiscoveryAgent

public void setDiscoveryAgent(DiscoveryAgent discoveryAgent)

setParameters

public void setParameters(Map<String,String> parameters)