org.apache.activemq.transport.vm
public class VMTransportServer extends java.lang.Object implements TransportServer
Constructor and Description |
---|
VMTransportServer(java.net.URI location,
boolean disposeOnDisconnect) |
Modifier and Type | Method and Description |
---|---|
static Transport |
configure(Transport transport)
Configure transport
|
VMTransport |
connect() |
java.net.URI |
getBindURI() |
int |
getConnectionCount() |
java.net.URI |
getConnectURI() |
java.net.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() |
java.lang.String |
toString() |
public VMTransportServer(java.net.URI location, boolean disposeOnDisconnect)
location
- disposeOnDisconnect
- public java.lang.String toString()
toString
in class java.lang.Object
public VMTransport connect() throws java.io.IOException
java.io.IOException
public static Transport configure(Transport transport)
transport
- public void setAcceptListener(TransportAcceptListener acceptListener)
setAcceptListener
in interface TransportServer
acceptListener
- public void start() throws java.io.IOException
public void stop() throws java.io.IOException
public java.net.URI getConnectURI()
getConnectURI
in interface TransportServer
public java.net.URI getBindURI()
public void setBrokerInfo(BrokerInfo brokerInfo)
TransportServer
setBrokerInfo
in interface TransportServer
public java.net.InetSocketAddress getSocketAddress()
getSocketAddress
in interface TransportServer
public int getConnectionCount()
Copyright © 2005-2014. All Rights Reserved.