public class TransportServerFilter extends Object implements TransportServer
Modifier and Type | Field and Description |
---|---|
protected TransportServer |
next |
Constructor and Description |
---|
TransportServerFilter(TransportServer next) |
Modifier and Type | Method and 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
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() |
protected final TransportServer next
public TransportServerFilter(TransportServer next)
next
- public URI getConnectURI()
getConnectURI
in interface TransportServer
public void setAcceptListener(TransportAcceptListener acceptListener)
TransportServer
TransportAcceptListener
which is notified of accepted
channels.setAcceptListener
in interface TransportServer
public void setBrokerInfo(BrokerInfo brokerInfo)
TransportServer
setBrokerInfo
in interface TransportServer
public InetSocketAddress getSocketAddress()
getSocketAddress
in interface TransportServer
public boolean isSslServer()
TransportServer
isSslServer
in interface TransportServer
public boolean isAllowLinkStealing()
TransportServer
isAllowLinkStealing
in interface TransportServer
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.