org.apache.activemq.transport

Class TransportServerFilter

java.lang.Object

org.apache.activemq.transport.TransportServerFilter

All Implemented Interfaces:

Service, TransportServer

public class TransportServerFilter
extends Object
implements TransportServer

Field Summary

Fields

Modifier and Type	Field and Description
protected TransportServer	next

Constructor Summary

Constructors

Constructor and Description
TransportServerFilter(TransportServer next)

Method Summary

Methods

Modifier and Type	Method and Description
URI	getConnectURI()
InetSocketAddress	getSocketAddress()
void	setAcceptListener(TransportAcceptListener acceptListener) Registers an TransportAcceptListener which is notified of accepted channels.
void	setBrokerInfo(BrokerInfo brokerInfo) Associates a broker info with the transport server so that the transport can do discovery advertisements of the broker.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

next

protected final TransportServer next

Constructor Detail

TransportServerFilter

public TransportServerFilter(TransportServer next)

Parameters:

next -

Method Detail

getConnectURI

public URI getConnectURI()

Specified by:

getConnectURI in interface TransportServer

setAcceptListener

public void setAcceptListener(TransportAcceptListener acceptListener)

Description copied from interface: TransportServer

Registers an TransportAcceptListener which is notified of accepted channels.

Specified by:

setAcceptListener in interface TransportServer

setBrokerInfo

public void setBrokerInfo(BrokerInfo brokerInfo)

Description copied from interface: TransportServer

Associates a broker info with the transport server so that the transport can do discovery advertisements of the broker.

Specified by:

setBrokerInfo in interface TransportServer

start

public void start()
           throws Exception

Specified by:

start in interface Service

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Service

Throws:

Exception

getSocketAddress

public InetSocketAddress getSocketAddress()

Specified by:

getSocketAddress in interface TransportServer

Returns:

The socket address that this transport is accepting connections on or null if this does not or is not currently accepting connections on a socket.