@Deprecated public class UdpTransportServer extends TransportServerSupport
TransportServer
transportOptions
Constructor and Description |
---|
UdpTransportServer(URI connectURI,
UdpTransport serverTransport,
Transport configuredTransport,
ReplayStrategy replayStrategy)
Deprecated.
|
Modifier and Type | Method and 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.
|
getAcceptListener, getBindLocation, getConnectURI, onAcceptError, setAcceptListener, setBindLocation, setConnectURI, setTransportOption
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
public UdpTransportServer(URI connectURI, UdpTransport serverTransport, Transport configuredTransport, ReplayStrategy replayStrategy)
public void run()
public UdpTransport getServerTransport()
public void setBrokerInfo(BrokerInfo brokerInfo)
TransportServer
protected void doStart() throws Exception
doStart
in class ServiceSupport
Exception
protected void doStop(ServiceStopper stopper) throws Exception
doStop
in class ServiceSupport
Exception
protected void processInboundConnection(Command command)
protected Transport configureTransport(Transport transport)
protected Transport createTransport(Command command, DatagramEndpoint endpoint) throws IOException
IOException
public InetSocketAddress getSocketAddress()
public boolean isSslServer()
TransportServer
public boolean isAllowLinkStealing()
TransportServer
isAllowLinkStealing
in interface TransportServer
isAllowLinkStealing
in class TransportServerSupport
public void setAllowLinkStealing(boolean allowLinkStealing)
setAllowLinkStealing
in class TransportServerSupport
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.