public class TransportServerFilter extends java.lang.Object implements TransportServer
Modifier and Type | Field and Description |
---|---|
protected TransportServer |
next |
Constructor and Description |
---|
TransportServerFilter(TransportServer next) |
Modifier and Type | Method and Description |
---|---|
java.net.URI |
getConnectURI() |
java.net.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 java.net.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 java.lang.Exception
public void stop() throws java.lang.Exception
public java.net.InetSocketAddress getSocketAddress()
getSocketAddress
in interface TransportServer
Copyright © 2005-2012. All Rights Reserved.