Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » transport » udp » [javadoc | source]
org.apache.activemq.transport.udp
public class: UdpTransport [javadoc | source]
java.lang.Object
   org.apache.activemq.util.ServiceSupport
      org.apache.activemq.transport.TransportSupport
         org.apache.activemq.transport.TransportThreadSupport
            org.apache.activemq.transport.udp.UdpTransport

All Implemented Interfaces:
    Service, Transport, Runnable

Direct Known Subclasses:
    MulticastTransport

An implementation of the Transport interface using raw UDP
Fields inherited from org.apache.activemq.transport.TransportSupport:
transportListener
Constructor:
 protected UdpTransport(OpenWireFormat wireFormat) throws IOException 
 public UdpTransport(OpenWireFormat wireFormat,
    URI remoteLocation) throws UnknownHostException, IOException 
 public UdpTransport(OpenWireFormat wireFormat,
    SocketAddress socketAddress) throws IOException 
 public UdpTransport(OpenWireFormat wireFormat,
    int port) throws UnknownHostException, IOException 
    Used by the server transport
Method from org.apache.activemq.transport.udp.UdpTransport Summary:
bind,   connect,   createAddress,   createCommandChannel,   createCommandDatagramChannel,   createDatagramHeaderMarshaller,   createLocalAddress,   createReplayer,   doStart,   doStop,   getBufferPool,   getChannel,   getCommandChannel,   getDatagramSize,   getLocalSocketAddress,   getMinmumWireFormatVersion,   getPort,   getProtocolName,   getProtocolUriScheme,   getReceiveCounter,   getRemoteAddress,   getReplayBuffer,   getReplayStrategy,   getSequenceGenerator,   getTargetAddress,   getWireFormat,   isReplayEnabled,   isTrace,   isUseLocalHost,   oneway,   oneway,   resolveHostName,   run,   setBufferPool,   setChannel,   setCommandChannel,   setDatagramSize,   setMinmumWireFormatVersion,   setPort,   setReplayBuffer,   setReplayEnabled,   setReplayStrategy,   setSequenceGenerator,   setTargetEndpoint,   setTrace,   setUseLocalHost,   toString
Methods from org.apache.activemq.transport.TransportThreadSupport:
doStart,   getStackSize,   isDaemon,   setDaemon,   setStackSize
Methods from org.apache.activemq.transport.TransportSupport:
asyncRequest,   checkStarted,   doConsume,   getTransportListener,   isConnected,   isDisposed,   isFaultTolerant,   narrow,   onException,   reconnect,   request,   request,   setTransportListener
Methods from org.apache.activemq.util.ServiceSupport:
addServiceListener,   dispose,   doStart,   doStop,   isStarted,   isStopped,   isStopping,   removeServiceListener,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.transport.udp.UdpTransport Detail:
 protected  void bind(DatagramSocket socket,
    SocketAddress localAddress) throws IOException 
 protected DatagramChannel connect(DatagramChannel channel,
    SocketAddress targetAddress2) throws IOException 
 protected InetSocketAddress createAddress(URI remoteLocation) throws UnknownHostException, IOException 
    Creates an address from the given URI
 protected CommandChannel createCommandChannel() throws IOException 
 protected CommandChannel createCommandDatagramChannel() 
 protected DatagramHeaderMarshaller createDatagramHeaderMarshaller() 
 protected SocketAddress createLocalAddress() 
 public Replayer createReplayer() throws IOException 
    Creates a replayer for working with the reliable transport
 protected  void doStart() throws Exception 
 protected  void doStop(ServiceStopper stopper) throws Exception 
 public ByteBufferPool getBufferPool() 
 protected DatagramChannel getChannel() 
 public CommandChannel getCommandChannel() throws IOException 
 public int getDatagramSize() 
 public InetSocketAddress getLocalSocketAddress() 
 public int getMinmumWireFormatVersion() 
 public int getPort() 
 protected String getProtocolName() 
 protected String getProtocolUriScheme() 
 public int getReceiveCounter() 
 public String getRemoteAddress() 
 public ReplayBuffer getReplayBuffer() 
 public ReplayStrategy getReplayStrategy() 
 public IntSequenceGenerator getSequenceGenerator() 
 protected SocketAddress getTargetAddress() 
 public OpenWireFormat getWireFormat() 
 public boolean isReplayEnabled() 
 public boolean isTrace() 
 public boolean isUseLocalHost() 
 public  void oneway(Object command) throws IOException 
    A one way asynchronous send
 public  void oneway(Object command,
    SocketAddress address) throws IOException 
    A one way asynchronous send to a given address
 protected String resolveHostName(String host) throws UnknownHostException 
 public  void run() 
    reads packets from a Socket
 public  void setBufferPool(ByteBufferPool bufferPool) 
 protected  void setChannel(DatagramChannel channel) 
 public  void setCommandChannel(CommandDatagramChannel commandChannel) 
    Sets the implementation of the command channel to use.
 public  void setDatagramSize(int datagramSize) 
 public  void setMinmumWireFormatVersion(int minmumWireFormatVersion) 
 public  void setPort(int port) 
    Sets the port to connect on
 public  void setReplayBuffer(ReplayBuffer replayBuffer) throws IOException 
 public  void setReplayEnabled(boolean replayEnabled) 
    Sets whether or not replay should be enabled when using the reliable transport. i.e. should we maintain a buffer of messages that can be replayed?
 public  void setReplayStrategy(ReplayStrategy replayStrategy) 
    Sets the strategy used to replay missed datagrams
 public  void setSequenceGenerator(IntSequenceGenerator sequenceGenerator) 
 public  void setTargetEndpoint(Endpoint newTarget) 
    We have received the WireFormatInfo from the server on the actual channel we should use for all future communication with the server, so lets set the target to be the actual channel that the server has chosen for us to talk on.
 public  void setTrace(boolean trace) 
 public  void setUseLocalHost(boolean useLocalHost) 
    Sets whether 'localhost' or the actual local host name should be used to make local connections. On some operating systems such as Macs its not possible to connect as the local host name so localhost is better.
 public String toString()