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() |
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 void start() throws Exception
public InetSocketAddress getSocketAddress()
getSocketAddress
in interface TransportServer
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.