org.apache.activemq.transport.udp
Class DatagramHeaderMarshaller
java.lang.Object
org.apache.activemq.transport.udp.DatagramHeaderMarshaller
- Direct Known Subclasses:
- MulticastDatagramHeaderMarshaller
public class DatagramHeaderMarshaller
- extends Object
- Version:
- $Revision: 426366 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DatagramHeaderMarshaller
public DatagramHeaderMarshaller()
createEndpoint
public Endpoint createEndpoint(ByteBuffer readBuffer,
SocketAddress address)
- Reads any header if applicable and then creates an endpoint object
createEndpoint
public Endpoint createEndpoint(DatagramPacket datagram,
DataInputStream dataIn)
writeHeader
public void writeHeader(Command command,
ByteBuffer writeBuffer)
writeHeader
public void writeHeader(Command command,
DataOutputStream dataOut)
getEndpoint
protected Endpoint getEndpoint(SocketAddress address)
- Gets the current endpoint object for this address or creates one if not available.
Note that this method does not need to be synchronized as its only ever going to be
used by the already-synchronized read() method of a CommandChannel
createEndpoint
protected Endpoint createEndpoint(SocketAddress address)
Copyright © 2011 Apache Software Foundation. All Rights Reserved.