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 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
UdpTransportServer
public UdpTransportServer(java.net.URI connectURI,
UdpTransport serverTransport,
Transport configuredTransport,
ReplayStrategy replayStrategy)
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.
Copyright © 2011 Apache Software Foundation. All Rights Reserved.