org.apache.activemq.transport.udp

Class UdpTransport

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.transport.TransportSupport

org.apache.activemq.transport.TransportThreadSupport

org.apache.activemq.transport.udp.UdpTransport

All Implemented Interfaces:

java.lang.Runnable, Service, Transport

Direct Known Subclasses:

MulticastTransport

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

An implementation of the Transport interface using raw UDP

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	UdpTransport(OpenWireFormat wireFormat)
	UdpTransport(OpenWireFormat wireFormat, int port) Used by the server transport
	UdpTransport(OpenWireFormat wireFormat, java.net.SocketAddress socketAddress)
	UdpTransport(OpenWireFormat wireFormat, java.net.URI remoteLocation)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	bind(java.net.DatagramSocket socket, java.net.SocketAddress localAddress)
protected java.nio.channels.DatagramChannel	connect(java.nio.channels.DatagramChannel channel, java.net.SocketAddress targetAddress2)
protected java.net.InetSocketAddress	createAddress(java.net.URI remoteLocation) Creates an address from the given URI
protected CommandChannel	createCommandChannel()
protected CommandChannel	createCommandDatagramChannel()
protected DatagramHeaderMarshaller	createDatagramHeaderMarshaller()
protected java.net.SocketAddress	createLocalAddress()
Replayer	createReplayer() Creates a replayer for working with the reliable transport
protected void	doStart()
protected void	doStop(ServiceStopper stopper)
ByteBufferPool	getBufferPool()
protected java.nio.channels.DatagramChannel	getChannel()
CommandChannel	getCommandChannel()
int	getDatagramSize()
java.net.InetSocketAddress	getLocalSocketAddress()
int	getMinmumWireFormatVersion()
int	getPort()
protected java.lang.String	getProtocolName()
protected java.lang.String	getProtocolUriScheme()
int	getReceiveCounter() Returns a counter which gets incremented as data is read from the transport.
java.lang.String	getRemoteAddress()
ReplayBuffer	getReplayBuffer()
ReplayStrategy	getReplayStrategy()
IntSequenceGenerator	getSequenceGenerator()
protected java.net.SocketAddress	getTargetAddress()
OpenWireFormat	getWireFormat()
boolean	isReplayEnabled()
boolean	isTrace()
boolean	isUseLocalHost()
void	oneway(java.lang.Object command) A one way asynchronous send
void	oneway(java.lang.Object command, java.net.SocketAddress address) A one way asynchronous send to a given address
protected java.lang.String	resolveHostName(java.lang.String host)
void	run() reads packets from a Socket
void	setBufferPool(ByteBufferPool bufferPool)
protected void	setChannel(java.nio.channels.DatagramChannel channel)
void	setCommandChannel(CommandDatagramChannel commandChannel) Sets the implementation of the command channel to use.
void	setDatagramSize(int datagramSize)
void	setMinmumWireFormatVersion(int minmumWireFormatVersion)
void	setPort(int port) Sets the port to connect on
void	setReplayBuffer(ReplayBuffer replayBuffer)
void	setReplayEnabled(boolean replayEnabled) Sets whether or not replay should be enabled when using the reliable transport.
void	setReplayStrategy(ReplayStrategy replayStrategy) Sets the strategy used to replay missed datagrams
void	setSequenceGenerator(IntSequenceGenerator sequenceGenerator)
void	setTargetEndpoint(Endpoint newTarget) We have received the WireFormatInfo from the server on the actual channel we should use for all future communication with the server, so lets set the target to be the actual channel that the server has chosen for us to talk on.
void	setTrace(boolean trace)
void	setUseLocalHost(boolean useLocalHost) Sets whether 'localhost' or the actual local host name should be used to make local connections.
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, narrow, onException, reconnect, request, request, setTransportListener, updateURIs

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

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

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, narrow, reconnect, request, request, setTransportListener, updateURIs

Methods inherited from interface org.apache.activemq.Service

start, stop

Constructor Detail

UdpTransport

protected UdpTransport(OpenWireFormat wireFormat)
                throws java.io.IOException

Throws:

java.io.IOException

UdpTransport

public UdpTransport(OpenWireFormat wireFormat,
            java.net.URI remoteLocation)
             throws java.net.UnknownHostException,
                    java.io.IOException

Throws:

java.net.UnknownHostException

java.io.IOException

UdpTransport

public UdpTransport(OpenWireFormat wireFormat,
            java.net.SocketAddress socketAddress)
             throws java.io.IOException

Throws:

java.io.IOException

UdpTransport

public UdpTransport(OpenWireFormat wireFormat,
            int port)
             throws java.net.UnknownHostException,
                    java.io.IOException

Used by the server transport

Throws:

java.net.UnknownHostException

java.io.IOException

Method Detail

createReplayer

public Replayer createReplayer()
                        throws java.io.IOException

Creates a replayer for working with the reliable transport

Throws:

java.io.IOException

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

oneway

public void oneway(java.lang.Object command,
          java.net.SocketAddress address)
            throws java.io.IOException

A one way asynchronous send to a given address

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

setTargetEndpoint

public void setTargetEndpoint(Endpoint newTarget)

We have received the WireFormatInfo from the server on the actual channel we should use for all future communication with the server, so lets set the target to be the actual channel that the server has chosen for us to talk on.

isTrace

public boolean isTrace()

setTrace

public void setTrace(boolean trace)

getDatagramSize

public int getDatagramSize()

setDatagramSize

public void setDatagramSize(int datagramSize)

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.

getCommandChannel

public CommandChannel getCommandChannel()
                                 throws java.io.IOException

Throws:

java.io.IOException

setCommandChannel

public void setCommandChannel(CommandDatagramChannel commandChannel)

Sets the implementation of the command channel to use.

getReplayStrategy

public ReplayStrategy getReplayStrategy()

setReplayStrategy

public void setReplayStrategy(ReplayStrategy replayStrategy)

Sets the strategy used to replay missed datagrams

getPort

public int getPort()

setPort

public void setPort(int port)

Sets the port to connect on

getMinmumWireFormatVersion

public int getMinmumWireFormatVersion()

setMinmumWireFormatVersion

public void setMinmumWireFormatVersion(int minmumWireFormatVersion)

getWireFormat

public OpenWireFormat getWireFormat()

getSequenceGenerator

public IntSequenceGenerator getSequenceGenerator()

setSequenceGenerator

public void setSequenceGenerator(IntSequenceGenerator sequenceGenerator)

isReplayEnabled

public boolean isReplayEnabled()

setReplayEnabled

public void setReplayEnabled(boolean replayEnabled)

Sets whether or not replay should be enabled when using the reliable transport. i.e. should we maintain a buffer of messages that can be replayed?

getBufferPool

public ByteBufferPool getBufferPool()

setBufferPool

public void setBufferPool(ByteBufferPool bufferPool)

getReplayBuffer

public ReplayBuffer getReplayBuffer()

setReplayBuffer

public void setReplayBuffer(ReplayBuffer replayBuffer)
                     throws java.io.IOException

Throws:

java.io.IOException

createAddress

protected java.net.InetSocketAddress createAddress(java.net.URI remoteLocation)
                                            throws java.net.UnknownHostException,
                                                   java.io.IOException

Creates an address from the given URI

Throws:

java.net.UnknownHostException

java.io.IOException

resolveHostName

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

Throws:

java.net.UnknownHostException

doStart

protected void doStart()
                throws java.lang.Exception

Overrides:

doStart in class TransportThreadSupport

Throws:

java.lang.Exception

createCommandChannel

protected CommandChannel createCommandChannel()
                                       throws java.io.IOException

Throws:

java.io.IOException

createCommandDatagramChannel

protected CommandChannel createCommandDatagramChannel()

bind

protected void bind(java.net.DatagramSocket socket,
        java.net.SocketAddress localAddress)
             throws java.io.IOException

Throws:

java.io.IOException

connect

protected java.nio.channels.DatagramChannel connect(java.nio.channels.DatagramChannel channel,
                                        java.net.SocketAddress targetAddress2)
                                             throws java.io.IOException

Throws:

java.io.IOException

createLocalAddress

protected java.net.SocketAddress createLocalAddress()

doStop

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

Specified by:

doStop in class ServiceSupport

Throws:

java.lang.Exception

createDatagramHeaderMarshaller

protected DatagramHeaderMarshaller createDatagramHeaderMarshaller()

getProtocolName

protected java.lang.String getProtocolName()

getProtocolUriScheme

protected java.lang.String getProtocolUriScheme()

getTargetAddress

protected java.net.SocketAddress getTargetAddress()

getChannel

protected java.nio.channels.DatagramChannel getChannel()

setChannel

protected void setChannel(java.nio.channels.DatagramChannel channel)

getLocalSocketAddress

public java.net.InetSocketAddress getLocalSocketAddress()

getRemoteAddress

public java.lang.String getRemoteAddress()

Specified by:

getRemoteAddress in interface Transport

Returns:

the remote address for this connection

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.