Package 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 Object
implements TransportServer

Broker side of the VMTransport

Constructor Summary

Constructors

Constructor	Description
VMTransportServer(URI location, boolean disposeOnDisconnect)

Method Summary

Modifier and Type	Method	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()

Methods inherited from class java.lang.Object

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

Constructor Detail

VMTransportServer

public VMTransportServer(URI location,
                         boolean disposeOnDisconnect)

Parameters:

location -

disposeOnDisconnect -

Method Detail

toString

public String toString()

Overrides:

toString in class Object

Returns:

a pretty print of this

connect

public VMTransport connect()
                    throws IOException

Returns:

new VMTransport

Throws:

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 IOException

Specified by:

start in interface Service

Throws:

IOException

stop

public void stop()
          throws IOException

Specified by:

stop in interface Service

Throws:

IOException

getConnectURI

public URI getConnectURI()

Specified by:

getConnectURI in interface TransportServer

getBindURI

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

isSslServer

public boolean isSslServer()

Description copied from interface: TransportServer

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.

Specified by:

isSslServer in interface TransportServer

Returns:

true if this transport server provides SSL level security over its connections.

isAllowLinkStealing

public boolean isAllowLinkStealing()

Description copied from interface: TransportServer

Some protocols allow link stealing by default (if 2 connections have the same clientID - the youngest wins). This is the default for AMQP and MQTT. However, JMS 1.1 spec requires the opposite

Specified by:

isAllowLinkStealing in interface TransportServer

Returns:

true if allow link stealing is enabled.

setAllowLinkStealing

public void setAllowLinkStealing(boolean allowLinkStealing)