public class VMTransportServer extends Object implements TransportServer
Constructor and Description |
---|
VMTransportServer(URI location,
boolean disposeOnDisconnect) |
Modifier and Type | Method and Description |
---|---|
static Transport |
configure(Transport transport)
Configure transport
|
VMTransport |
connect() |
URI |
getBindURI() |
int |
getConnectionCount() |
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)
Set the Transport accept listener for new Connections
|
void |
setAllowLinkStealing(boolean allowLinkStealing) |
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() |
String |
toString() |
public VMTransportServer(URI location, boolean disposeOnDisconnect)
location
- disposeOnDisconnect
- public VMTransport connect() throws IOException
IOException
public static Transport configure(Transport transport)
transport
- public void setAcceptListener(TransportAcceptListener acceptListener)
setAcceptListener
in interface TransportServer
acceptListener
- public void start() throws IOException
start
in interface Service
IOException
public void stop() throws IOException
stop
in interface Service
IOException
public URI getConnectURI()
getConnectURI
in interface TransportServer
public URI getBindURI()
public void setBrokerInfo(BrokerInfo brokerInfo)
TransportServer
setBrokerInfo
in interface TransportServer
public InetSocketAddress getSocketAddress()
getSocketAddress
in interface TransportServer
public int getConnectionCount()
public boolean isSslServer()
TransportServer
isSslServer
in interface TransportServer
public boolean isAllowLinkStealing()
TransportServer
isAllowLinkStealing
in interface TransportServer
public void setAllowLinkStealing(boolean allowLinkStealing)
Copyright © 2005–2018 The Apache Software Foundation. All rights reserved.