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
- Version:
- $Revision: 464110 $
UdpTransportServer
public UdpTransportServer(URI connectURI,
UdpTransport serverTransport,
Transport configuredTransport,
ReplayStrategy replayStrategy)
toString
public String toString()
- Overrides:
toString
in class 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 Exception
- Specified by:
doStart
in class ServiceSupport
- Throws:
Exception
doStop
protected void doStop(ServiceStopper stopper)
throws Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
Exception
processInboundConnection
protected void processInboundConnection(Command command)
configureTransport
protected Transport configureTransport(Transport transport)
createTransport
protected Transport createTransport(Command command,
DatagramEndpoint endpoint)
throws IOException
- Throws:
IOException
getSocketAddress
public 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.
Copyright © 2011 Apache Software Foundation. All Rights Reserved.