org.apache.activemq.transport
Class TransportServerFilter

java.lang.Object
  extended by org.apache.activemq.transport.TransportServerFilter
All Implemented Interfaces:
Service, TransportServer

public class TransportServerFilter
extends Object
implements TransportServer


Field Summary
protected  TransportServer next
           
 
Constructor Summary
TransportServerFilter(TransportServer next)
           
 
Method Summary
 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.


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.