org.apache.activemq.transport.udp
Class DatagramHeaderMarshaller

java.lang.Object
  extended by org.apache.activemq.transport.udp.DatagramHeaderMarshaller
Direct Known Subclasses:
MulticastDatagramHeaderMarshaller

public class DatagramHeaderMarshaller
extends Object


Constructor Summary
DatagramHeaderMarshaller()
           
 
Method Summary
 Endpoint createEndpoint(ByteBuffer readBuffer, SocketAddress address)
          Reads any header if applicable and then creates an endpoint object
 Endpoint createEndpoint(DatagramPacket datagram, DataInputStream dataIn)
           
protected  Endpoint createEndpoint(SocketAddress address)
           
protected  Endpoint getEndpoint(SocketAddress address)
          Gets the current endpoint object for this address or creates one if not available.
 void writeHeader(Command command, ByteBuffer writeBuffer)
           
 void writeHeader(Command command, DataOutputStream dataOut)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DatagramHeaderMarshaller

public DatagramHeaderMarshaller()
Method Detail

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 © 2005-2012 The Apache Software Foundation. All Rights Reserved.