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() |
void |
setAcceptListener(TransportAcceptListener acceptListener)
Set the Transport accept listener for new Connections
|
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 String toString()
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()
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.