Package 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 Description protected TransportServer
next
-
Constructor Summary
Constructors Constructor Description TransportServerFilter(TransportServer next)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description URI
getConnectURI()
InetSocketAddress
getSocketAddress()
boolean
isAllowLinkStealing()
Some protocols allow link stealing by default (if 2 connections have the same clientID - the youngest wins).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 {@see 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()
-
-
-
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 interfaceTransportServer
-
setAcceptListener
public void setAcceptListener(TransportAcceptListener acceptListener)
Description copied from interface:TransportServer
Registers an {@see TransportAcceptListener} which is notified of accepted channels.- Specified by:
setAcceptListener
in interfaceTransportServer
-
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 interfaceTransportServer
-
start
public void start() throws Exception
-
getSocketAddress
public InetSocketAddress getSocketAddress()
- Specified by:
getSocketAddress
in interfaceTransportServer
- 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 interfaceTransportServer
- Returns:
- true if this transport server provides SSL level security over its connections.
-
isAllowLinkStealing
public boolean isAllowLinkStealing()
Description copied from interface:TransportServer
Some protocols allow link stealing by default (if 2 connections have the same clientID - the youngest wins). This is the default for AMQP and MQTT. However, JMS 1.1 spec requires the opposite- Specified by:
isAllowLinkStealing
in interfaceTransportServer
- Returns:
- true if allow link stealing is enabled.
-
-