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()
           
 boolean isSslServer()
          For TransportServers that provide SSL connections to their connected peers they should return true here if and only if they populate the ConnectionInfo command presented to the Broker with the peers certificate chain so that the broker knows it can use that information to authenticate the connected peer.
 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.

isSslServer

public boolean isSslServer()
Description copied from interface: TransportServer
For TransportServers that provide SSL connections to their connected peers they should return true here if and only if they populate the ConnectionInfo command presented to the Broker with the peers certificate chain so that the broker knows it can use that information to authenticate the connected peer.

Specified by:
isSslServer in interface TransportServer
Returns:
true if this transport server provides SSL level security over its connections.


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