org.apache.activemq.transport.vm
Class VMTransportServer

java.lang.Object
  org.apache.activemq.transport.vm.VMTransportServer

All Implemented Interfaces:

Service, TransportServer

public class VMTransportServer
extends java.lang.Object
implements TransportServer

Broker side of the VMTransport

Constructor Summary

VMTransportServer(java.net.URI location, boolean disposeOnDisconnect)

Method Summary

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

VMTransportServer

public VMTransportServer(java.net.URI location,
                         boolean disposeOnDisconnect)

Parameters:

location -

disposeOnDisconnect -

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

Returns:

a pretty print of this

connect

public VMTransport connect()
                    throws java.io.IOException

Returns:

new VMTransport

Throws:

java.io.IOException

configure

public static Transport configure(Transport transport)

Configure transport

Parameters:

transport -

Returns:

the Transport

setAcceptListener

public void setAcceptListener(TransportAcceptListener acceptListener)

Set the Transport accept listener for new Connections

Specified by:

setAcceptListener in interface TransportServer

Parameters:

acceptListener -

start

public void start()
           throws java.io.IOException

Specified by:

start in interface Service

Throws:

java.io.IOException

stop

public void stop()
          throws java.io.IOException

Specified by:

stop in interface Service

Throws:

java.io.IOException

getConnectURI

public java.net.URI getConnectURI()

Specified by:

getConnectURI in interface TransportServer

getBindURI

public java.net.URI getBindURI()

setBrokerInfo

public void setBrokerInfo(BrokerInfo brokerInfo)

Description copied from interface: TransportServer

Associates a broker info with the transport server so that the transport can do discovery advertisements of the broker.

Specified by:

setBrokerInfo in interface TransportServer

getSocketAddress

public java.net.InetSocketAddress getSocketAddress()

Specified by:

getSocketAddress in interface TransportServer

Returns:

The socket address that this transport is accepting connections on or null if this does not or is not currently accepting connections on a socket.

getConnectionCount

public int getConnectionCount()