org.apache.activemq.transport

Class TransportServerSupport

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.transport.TransportServerSupport

All Implemented Interfaces:

Service, TransportServer

Direct Known Subclasses:

TransportServerThreadSupport, UdpTransportServer

public abstract class TransportServerSupport
extends ServiceSupport
implements TransportServer

A useful base class for implementations of TransportServer

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	allowLinkStealing
protected java.util.Map<java.lang.String,java.lang.Object>	transportOptions

Constructor Summary

Constructors

Constructor and Description
TransportServerSupport()
TransportServerSupport(java.net.URI location)

Method Summary

Methods

Modifier and Type	Method and Description
TransportAcceptListener	getAcceptListener()
java.net.URI	getBindLocation()
java.net.URI	getConnectURI()
boolean	isAllowLinkStealing() Some protocols allow link stealing by default (if 2 connections have the same clientID - the youngest wins).
protected void	onAcceptError(java.lang.Exception e)
void	setAcceptListener(TransportAcceptListener acceptListener) Registers an accept listener
void	setAllowLinkStealing(boolean allowLinkStealing)
void	setBindLocation(java.net.URI bindLocation)
void	setConnectURI(java.net.URI location)
void	setTransportOption(java.util.Map<java.lang.String,java.lang.Object> transportOptions)

Methods inherited from class org.apache.activemq.util.ServiceSupport

addServiceListener, dispose, doStart, doStop, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.transport.TransportServer

getSocketAddress, isSslServer, setBrokerInfo

Methods inherited from interface org.apache.activemq.Service

start, stop

Field Detail

transportOptions

protected java.util.Map<java.lang.String,java.lang.Object> transportOptions

allowLinkStealing

protected boolean allowLinkStealing

Constructor Detail

TransportServerSupport

public TransportServerSupport()

TransportServerSupport

public TransportServerSupport(java.net.URI location)

Method Detail

getAcceptListener

public TransportAcceptListener getAcceptListener()

Returns:

Returns the acceptListener.

setAcceptListener

public void setAcceptListener(TransportAcceptListener acceptListener)

Registers an accept listener

Specified by:

setAcceptListener in interface TransportServer

Parameters:

acceptListener -

getConnectURI

public java.net.URI getConnectURI()

Specified by:

getConnectURI in interface TransportServer

Returns:

Returns the location.

setConnectURI

public void setConnectURI(java.net.URI location)

Parameters:

location - The location to set.

onAcceptError

protected void onAcceptError(java.lang.Exception e)

getBindLocation

public java.net.URI getBindLocation()

setBindLocation

public void setBindLocation(java.net.URI bindLocation)

setTransportOption

public void setTransportOption(java.util.Map<java.lang.String,java.lang.Object> transportOptions)

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:

setAllowLinkStealing

public void setAllowLinkStealing(boolean allowLinkStealing)