Package 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

@Deprecated
public class UdpTransportServer
extends TransportServerSupport

Deprecated.

A UDP based implementation of TransportServer

Field Summary

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

transportOptions

Constructor Summary

Constructors

Constructor	Description
UdpTransportServer(URI connectURI, UdpTransport serverTransport, Transport configuredTransport, ReplayStrategy replayStrategy)	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected Transport	configureTransport(Transport transport)	Deprecated.
protected Transport	createTransport(Command command, DatagramEndpoint endpoint)	Deprecated.
protected void	doStart()	Deprecated.
protected void	doStop(ServiceStopper stopper)	Deprecated.
UdpTransport	getServerTransport()	Deprecated.
InetSocketAddress	getSocketAddress()	Deprecated.
boolean	isAllowLinkStealing()	Deprecated. Some protocols allow link stealing by default (if 2 connections have the same clientID - the youngest wins).
boolean	isSslServer()	Deprecated. 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.
protected void	processInboundConnection(Command command)	Deprecated.
void	run()	Deprecated.
void	setAllowLinkStealing(boolean allowLinkStealing)	Deprecated.
void	setBrokerInfo(BrokerInfo brokerInfo)	Deprecated. Associates a broker info with the transport server so that the transport can do discovery advertisements of the broker.
String	toString()	Deprecated.

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, postStop, preStart, 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(URI connectURI,
                          UdpTransport serverTransport,
                          Transport configuredTransport,
                          ReplayStrategy replayStrategy)

Deprecated.

Method Detail

toString

public String toString()

Deprecated.

Overrides:

toString in class Object

run

public void run()

Deprecated.

getServerTransport

public UdpTransport getServerTransport()

Deprecated.

setBrokerInfo

public void setBrokerInfo(BrokerInfo brokerInfo)

Deprecated.

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 Exception

Deprecated.

Specified by:

doStart in class ServiceSupport

Throws:

Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws Exception

Deprecated.

Specified by:

doStop in class ServiceSupport

Throws:

Exception

processInboundConnection

protected void processInboundConnection(Command command)

Deprecated.

configureTransport

protected Transport configureTransport(Transport transport)

Deprecated.

createTransport

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

Deprecated.

Throws:

IOException

getSocketAddress

public InetSocketAddress getSocketAddress()

Deprecated.

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.

isSslServer

public boolean isSslServer()

Deprecated.

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.

Returns:

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

isAllowLinkStealing

public boolean isAllowLinkStealing()

Deprecated.

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

Overrides:

isAllowLinkStealing in class TransportServerSupport

Returns:

true if allow link stealing is enabled.

setAllowLinkStealing

public void setAllowLinkStealing(boolean allowLinkStealing)

Deprecated.

Overrides:

setAllowLinkStealing in class TransportServerSupport