org.apache.activemq.transport.udp

Class UdpTransportServer

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.transport.TransportServerSupport

org.apache.activemq.transport.udp.UdpTransportServer

All Implemented Interfaces:

Service, TransportServer

public class UdpTransportServer
extends TransportServerSupport

A UDP based implementation of TransportServer

Field Summary

Fields inherited from class org.apache.activemq.transport.TransportServerSupport

transportOptions

Constructor Summary

Constructors

Constructor and Description
UdpTransportServer(java.net.URI connectURI, UdpTransport serverTransport, Transport configuredTransport, ReplayStrategy replayStrategy)

Method Summary

Methods

Modifier and Type	Method and Description
protected Transport	configureTransport(Transport transport)
protected Transport	createTransport(Command command, DatagramEndpoint endpoint)
protected void	doStart()
protected void	doStop(ServiceStopper stopper)
UdpTransport	getServerTransport()
java.net.InetSocketAddress	getSocketAddress()
protected void	processInboundConnection(Command command)
void	run()
void	setBrokerInfo(BrokerInfo brokerInfo) Associates a broker info with the transport server so that the transport can do discovery advertisements of the broker.
java.lang.String	toString()

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

getAcceptListener, getBindLocation, getConnectURI, onAcceptError, setAcceptListener, setBindLocation, setConnectURI, setTransportOption

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.Service

start, stop

Constructor Detail

UdpTransportServer

public UdpTransportServer(java.net.URI connectURI,
                  UdpTransport serverTransport,
                  Transport configuredTransport,
                  ReplayStrategy replayStrategy)

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

run

public void run()

getServerTransport

public UdpTransport getServerTransport()

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.

doStart

protected void doStart()
                throws java.lang.Exception

Specified by:

doStart in class ServiceSupport

Throws:

java.lang.Exception

doStop

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

Specified by:

doStop in class ServiceSupport

Throws:

java.lang.Exception

processInboundConnection

protected void processInboundConnection(Command command)

configureTransport

protected Transport configureTransport(Transport transport)

createTransport

protected Transport createTransport(Command command,
                        DatagramEndpoint endpoint)
                             throws java.io.IOException

Throws:

java.io.IOException

getSocketAddress

public java.net.InetSocketAddress getSocketAddress()

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.