public class UdpTransportServer extends TransportServerSupport
TransportServer
transportOptions
Constructor and Description |
---|
UdpTransportServer(URI connectURI,
UdpTransport serverTransport,
Transport configuredTransport,
ReplayStrategy replayStrategy) |
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() |
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.
|
String |
toString() |
getAcceptListener, getBindLocation, getConnectURI, onAcceptError, setAcceptListener, setBindLocation, setConnectURI, setTransportOption
addServiceListener, dispose, isStarted, isStopped, isStopping, 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 createTransport(Command command, DatagramEndpoint endpoint) throws IOException
IOException
public InetSocketAddress getSocketAddress()
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.