org.apache.activemq.transport.udp
Class DatagramHeaderMarshaller
java.lang.Object
org.apache.activemq.transport.udp.DatagramHeaderMarshaller
- Direct Known Subclasses:
- MulticastDatagramHeaderMarshaller
public class DatagramHeaderMarshaller
- extends java.lang.Object
- Version:
- $Revision: 426366 $
Method Summary |
Endpoint |
createEndpoint(java.nio.ByteBuffer readBuffer,
java.net.SocketAddress address)
Reads any header if applicable and then creates an endpoint object |
Endpoint |
createEndpoint(java.net.DatagramPacket datagram,
java.io.DataInputStream dataIn)
|
protected Endpoint |
createEndpoint(java.net.SocketAddress address)
|
protected Endpoint |
getEndpoint(java.net.SocketAddress address)
Gets the current endpoint object for this address or creates one if not available. |
void |
writeHeader(Command command,
java.nio.ByteBuffer writeBuffer)
|
void |
writeHeader(Command command,
java.io.DataOutputStream dataOut)
|
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(java.nio.ByteBuffer readBuffer,
java.net.SocketAddress address)
- Reads any header if applicable and then creates an endpoint object
createEndpoint
public Endpoint createEndpoint(java.net.DatagramPacket datagram,
java.io.DataInputStream dataIn)
writeHeader
public void writeHeader(Command command,
java.nio.ByteBuffer writeBuffer)
writeHeader
public void writeHeader(Command command,
java.io.DataOutputStream dataOut)
getEndpoint
protected Endpoint getEndpoint(java.net.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(java.net.SocketAddress address)
Copyright © 2010 Apache Software Foundation. All Rights Reserved.