org.apache.activemq.transport.tcp

Class TcpTransport

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.transport.TransportSupport

org.apache.activemq.transport.TransportThreadSupport

org.apache.activemq.transport.tcp.TcpTransport

All Implemented Interfaces:

java.lang.Runnable, Service, Transport

Direct Known Subclasses:

MQTTNIOTransport, NIOTransport, SslTransport, StompNIOTransport

public class TcpTransport
extends TransportThreadSupport
implements Transport, Service, java.lang.Runnable

An implementation of the Transport interface using raw tcp/ip

Author:

David Martin Clavo david(dot)martin(dot)clavo(at)gmail.com (logging improvement modifications)

Field Summary

Fields

Modifier and Type	Field and Description
protected TimeStampStream	buffOut
protected boolean	closeAsync
protected int	connectionTimeout
protected java.io.DataInputStream	dataIn
protected java.io.DataOutputStream	dataOut
protected boolean	diffServChosen Prevents setting both the Differentiated Services and Type of Service transport options at the same time, since they share the same spot in the TCP/IP packet headers.
protected boolean	dynamicManagement Specifies if the TransportLogger will be manageable by JMX or not.
protected int	ioBufferSize
protected int	jmxPort Specifies the port that will be used by the JMX server to manage the TransportLoggers.
protected java.net.URI	localLocation
protected java.lang.String	logWriterName Name of the LogWriter implementation to use.
protected int	minmumWireFormatVersion
protected java.net.URI	remoteLocation
protected java.net.Socket	socket
protected int	socketBufferSize
protected javax.net.SocketFactory	socketFactory
protected int	soTimeout
protected boolean	startLogging startLogging=true -> the TransportLogger object of the Transport stack will initially write messages to the log.
protected java.util.concurrent.atomic.AtomicReference<java.util.concurrent.CountDownLatch>	stoppedLatch
protected boolean	trace trace=true -> the Transport stack where this TcpTransport object will be, will have a TransportLogger layer trace=false -> the Transport stack where this TcpTransport object will be, will NOT have a TransportLogger layer, and therefore will never be able to print logging messages.
protected int	trafficClass The Traffic Class to be set on the socket.
protected boolean	typeOfServiceChosen
protected boolean	useLocalHost
protected WireFormat	wireFormat

Constructor Summary

Constructors

Constructor and Description
TcpTransport(WireFormat wireFormat, java.net.Socket socket) Initialize from a server Socket
TcpTransport(WireFormat wireFormat, javax.net.SocketFactory socketFactory, java.net.URI remoteLocation, java.net.URI localLocation) Connect to a remote Node - e.g.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	closeStreams()
protected void	connect()
protected void	doRun()
protected void	doStart()
protected void	doStop(ServiceStopper stopper)
int	getConnectionTimeout()
java.lang.String	getDiffServ()
int	getIoBufferSize()
int	getJmxPort()
java.lang.Boolean	getKeepAlive()
java.lang.String	getLogWriterName()
int	getMinmumWireFormatVersion()
int	getReceiveCounter() Returns a counter which gets incremented as data is read from the transport.
java.lang.String	getRemoteAddress()
int	getSocketBufferSize()
int	getSoLinger()
int	getSoTimeout()
java.lang.Boolean	getTcpNoDelay()
int	getTypeOfService()
WireFormat	getWireFormat()
protected void	initialiseSocket(java.net.Socket sock) Configures the socket for use
protected void	initializeStreams()
boolean	isCloseAsync()
boolean	isDynamicManagement()
boolean	isStartLogging()
boolean	isTrace()
boolean	isUseLocalHost()
<T> T	narrow(java.lang.Class<T> target) narrow acceptance
void	oneway(java.lang.Object command) A one way asynchronous send
protected java.lang.Object	readCommand()
protected java.lang.String	resolveHostName(java.lang.String host)
void	run() reads packets from a Socket
void	setCloseAsync(boolean closeAsync)
void	setConnectionTimeout(int connectionTimeout) Sets the timeout used to connect to the socket
void	setDiffServ(java.lang.String diffServ)
void	setDynamicManagement(boolean useJmx)
void	setIoBufferSize(int ioBufferSize)
void	setJmxPort(int jmxPort)
void	setKeepAlive(java.lang.Boolean keepAlive) Enable/disable TCP KEEP_ALIVE mode
void	setLogWriterName(java.lang.String logFormat)
void	setMinmumWireFormatVersion(int minmumWireFormatVersion)
void	setSocketBufferSize(int socketBufferSize) Sets the buffer size to use on the socket
void	setSocketOptions(java.util.Map<java.lang.String,java.lang.Object> socketOptions)
void	setSoLinger(int soLinger) Enable/disable soLinger
void	setSoTimeout(int soTimeout) Sets the socket timeout
void	setStartLogging(boolean startLogging)
void	setTcpNoDelay(java.lang.Boolean tcpNoDelay) Enable/disable the TCP_NODELAY option on the socket
void	setTrace(boolean trace)
void	setTypeOfService(int typeOfService)
void	setUseLocalHost(boolean useLocalHost) Sets whether 'localhost' or the actual local host name should be used to make local connections.
void	stop() Override so that stop() blocks until the run thread is no longer running.
java.lang.String	toString()

Methods inherited from class org.apache.activemq.transport.TransportThreadSupport

getStackSize, isDaemon, setDaemon, setStackSize

Methods inherited from class org.apache.activemq.transport.TransportSupport

asyncRequest, checkStarted, doConsume, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, onException, reconnect, request, request, setTransportListener, updateURIs

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

addServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, start

Methods inherited from class java.lang.Object

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

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

asyncRequest, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, reconnect, request, request, setTransportListener, updateURIs

Methods inherited from interface org.apache.activemq.Service

start

Field Detail

remoteLocation

protected final java.net.URI remoteLocation

localLocation

protected final java.net.URI localLocation

wireFormat

protected final WireFormat wireFormat

connectionTimeout

protected int connectionTimeout

soTimeout

protected int soTimeout

socketBufferSize

protected int socketBufferSize

ioBufferSize

protected int ioBufferSize

closeAsync

protected boolean closeAsync

socket

protected java.net.Socket socket

dataOut

protected java.io.DataOutputStream dataOut

dataIn

protected java.io.DataInputStream dataIn

buffOut

protected TimeStampStream buffOut

trafficClass

protected int trafficClass

The Traffic Class to be set on the socket.

diffServChosen

protected boolean diffServChosen

Prevents setting both the Differentiated Services and Type of Service transport options at the same time, since they share the same spot in the TCP/IP packet headers.

typeOfServiceChosen

protected boolean typeOfServiceChosen

trace

protected boolean trace

trace=true -> the Transport stack where this TcpTransport object will be, will have a TransportLogger layer trace=false -> the Transport stack where this TcpTransport object will be, will NOT have a TransportLogger layer, and therefore will never be able to print logging messages. This parameter is most probably set in Connection or TransportConnector URIs.

logWriterName

protected java.lang.String logWriterName

Name of the LogWriter implementation to use. Names are mapped to classes in the resources/META-INF/services/org/apache/activemq/transport/logwriters directory. This parameter is most probably set in Connection or TransportConnector URIs.

dynamicManagement

protected boolean dynamicManagement

Specifies if the TransportLogger will be manageable by JMX or not. Also, as long as there is at least 1 TransportLogger which is manageable, a TransportLoggerControl MBean will me created.

startLogging

protected boolean startLogging

startLogging=true -> the TransportLogger object of the Transport stack will initially write messages to the log. startLogging=false -> the TransportLogger object of the Transport stack will initially NOT write messages to the log. This parameter only has an effect if trace == true. This parameter is most probably set in Connection or TransportConnector URIs.

jmxPort

protected int jmxPort

Specifies the port that will be used by the JMX server to manage the TransportLoggers. This should only be set in an URI by a client (producer or consumer) since a broker will already create a JMX server. It is useful for people who test a broker and clients in the same machine and want to control both via JMX; a different port will be needed.

useLocalHost

protected boolean useLocalHost

minmumWireFormatVersion

protected int minmumWireFormatVersion

socketFactory

protected javax.net.SocketFactory socketFactory

stoppedLatch

protected final java.util.concurrent.atomic.AtomicReference<java.util.concurrent.CountDownLatch> stoppedLatch

Constructor Detail

TcpTransport

public TcpTransport(WireFormat wireFormat,
            javax.net.SocketFactory socketFactory,
            java.net.URI remoteLocation,
            java.net.URI localLocation)
             throws java.net.UnknownHostException,
                    java.io.IOException

Connect to a remote Node - e.g. a Broker

Parameters:

wireFormat -

socketFactory -

remoteLocation -

localLocation - - e.g. local InetAddress and local port

Throws:

java.io.IOException

java.net.UnknownHostException

TcpTransport

public TcpTransport(WireFormat wireFormat,
            java.net.Socket socket)
             throws java.io.IOException

Initialize from a server Socket

Parameters:

wireFormat -

socket -

Throws:

java.io.IOException

Method Detail

oneway

public void oneway(java.lang.Object command)
            throws java.io.IOException

A one way asynchronous send

Specified by:

oneway in interface Transport

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

Returns:

pretty print of 'this'

run

public void run()

reads packets from a Socket

Specified by:

run in interface java.lang.Runnable

doRun

protected void doRun()
              throws java.io.IOException

Throws:

java.io.IOException

readCommand

protected java.lang.Object readCommand()
                                throws java.io.IOException

Throws:

java.io.IOException

getDiffServ

public java.lang.String getDiffServ()

setDiffServ

public void setDiffServ(java.lang.String diffServ)
                 throws java.lang.IllegalArgumentException

Throws:

java.lang.IllegalArgumentException

getTypeOfService

public int getTypeOfService()

setTypeOfService

public void setTypeOfService(int typeOfService)

isTrace

public boolean isTrace()

setTrace

public void setTrace(boolean trace)

getLogWriterName

public java.lang.String getLogWriterName()

setLogWriterName

public void setLogWriterName(java.lang.String logFormat)

isDynamicManagement

public boolean isDynamicManagement()

setDynamicManagement

public void setDynamicManagement(boolean useJmx)

isStartLogging

public boolean isStartLogging()

setStartLogging

public void setStartLogging(boolean startLogging)

getJmxPort

public int getJmxPort()

setJmxPort

public void setJmxPort(int jmxPort)

getMinmumWireFormatVersion

public int getMinmumWireFormatVersion()

setMinmumWireFormatVersion

public void setMinmumWireFormatVersion(int minmumWireFormatVersion)

isUseLocalHost

public boolean isUseLocalHost()

setUseLocalHost

public void setUseLocalHost(boolean useLocalHost)

Sets whether 'localhost' or the actual local host name should be used to make local connections. On some operating systems such as Macs its not possible to connect as the local host name so localhost is better.

getSocketBufferSize

public int getSocketBufferSize()

setSocketBufferSize

public void setSocketBufferSize(int socketBufferSize)

Sets the buffer size to use on the socket

getSoTimeout

public int getSoTimeout()

setSoTimeout

public void setSoTimeout(int soTimeout)

Sets the socket timeout

getConnectionTimeout

public int getConnectionTimeout()

setConnectionTimeout

public void setConnectionTimeout(int connectionTimeout)

Sets the timeout used to connect to the socket

getKeepAlive

public java.lang.Boolean getKeepAlive()

setKeepAlive

public void setKeepAlive(java.lang.Boolean keepAlive)

Enable/disable TCP KEEP_ALIVE mode

setSoLinger

public void setSoLinger(int soLinger)

Enable/disable soLinger

Parameters:

soLinger - enabled if > -1, disabled if == -1, system default otherwise

getSoLinger

public int getSoLinger()

getTcpNoDelay

public java.lang.Boolean getTcpNoDelay()

setTcpNoDelay

public void setTcpNoDelay(java.lang.Boolean tcpNoDelay)

Enable/disable the TCP_NODELAY option on the socket

getIoBufferSize

public int getIoBufferSize()

Returns:

the ioBufferSize

setIoBufferSize

public void setIoBufferSize(int ioBufferSize)

Parameters:

ioBufferSize - the ioBufferSize to set

isCloseAsync

public boolean isCloseAsync()

Returns:

the closeAsync

setCloseAsync

public void setCloseAsync(boolean closeAsync)

Parameters:

closeAsync - the closeAsync to set

resolveHostName

protected java.lang.String resolveHostName(java.lang.String host)
                                    throws java.net.UnknownHostException

Throws:

java.net.UnknownHostException

initialiseSocket

protected void initialiseSocket(java.net.Socket sock)
                         throws java.net.SocketException,
                                java.lang.IllegalArgumentException

Configures the socket for use

Parameters:

sock -

Throws:

SocketException, - IllegalArgumentException if setting the options on the socket failed.

java.net.SocketException

java.lang.IllegalArgumentException

doStart

protected void doStart()
                throws java.lang.Exception

Overrides:

doStart in class TransportThreadSupport

Throws:

java.lang.Exception

connect

protected void connect()
                throws java.lang.Exception

Throws:

java.lang.Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws java.lang.Exception

Specified by:

doStop in class ServiceSupport

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Override so that stop() blocks until the run thread is no longer running.

Specified by:

stop in interface Service

Overrides:

stop in class ServiceSupport

Throws:

java.lang.Exception

initializeStreams

protected void initializeStreams()
                          throws java.lang.Exception

Throws:

java.lang.Exception

closeStreams

protected void closeStreams()
                     throws java.io.IOException

Throws:

java.io.IOException

setSocketOptions

public void setSocketOptions(java.util.Map<java.lang.String,java.lang.Object> socketOptions)

getRemoteAddress

public java.lang.String getRemoteAddress()

Specified by:

getRemoteAddress in interface Transport

Returns:

the remote address for this connection

narrow

public <T> T narrow(java.lang.Class<T> target)

Description copied from class: TransportSupport

narrow acceptance

Specified by:

narrow in interface Transport

Overrides:

narrow in class TransportSupport

Returns:

'this' if assignable

getReceiveCounter

public int getReceiveCounter()

Description copied from interface: Transport

Returns a counter which gets incremented as data is read from the transport. It should only be used to determine if there is progress being made in reading the next command from the transport. The value may wrap into the negative numbers.

Specified by:

getReceiveCounter in interface Transport

Returns:

a counter which gets incremented as data is read from the transport.

getWireFormat

public WireFormat getWireFormat()