public interface TransportServer extends Service
Transport
objects and then
delivers those objects to a TransportAcceptListener
.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 setAcceptListener(TransportAcceptListener acceptListener)
TransportAcceptListener
which is notified of accepted
channels.acceptListener
- void setBrokerInfo(BrokerInfo brokerInfo)
brokerInfo
- URI getConnectURI()
InetSocketAddress getSocketAddress()
boolean isSslServer()
boolean isAllowLinkStealing()
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.