org.apache.activemq.transport.stomp
Class StompWireFormat

java.lang.Object
  extended by org.apache.activemq.transport.stomp.StompWireFormat
All Implemented Interfaces:
WireFormat

public class StompWireFormat
extends java.lang.Object
implements WireFormat

Implements marshalling and unmarsalling the Stomp protocol.


Constructor Summary
StompWireFormat()
           
 
Method Summary
 int getVersion()
           
 ByteSequence marshal(java.lang.Object command)
          Packet based marshaling
 void marshal(java.lang.Object command, java.io.DataOutput os)
          Stream based marshaling
protected  java.lang.String parseAction(java.io.DataInput in)
           
protected  int parseContentLength(java.lang.String contentLength)
           
protected  java.util.HashMap<java.lang.String,java.lang.String> parseHeaders(java.io.DataInput in)
           
 void setVersion(int version)
           
 java.lang.Object unmarshal(ByteSequence packet)
          Packet based un-marshaling
 java.lang.Object unmarshal(java.io.DataInput in)
          Packet based un-marshaling
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StompWireFormat

public StompWireFormat()
Method Detail

marshal

public ByteSequence marshal(java.lang.Object command)
                     throws java.io.IOException
Description copied from interface: WireFormat
Packet based marshaling

Specified by:
marshal in interface WireFormat
Throws:
java.io.IOException

unmarshal

public java.lang.Object unmarshal(ByteSequence packet)
                           throws java.io.IOException
Description copied from interface: WireFormat
Packet based un-marshaling

Specified by:
unmarshal in interface WireFormat
Throws:
java.io.IOException

marshal

public void marshal(java.lang.Object command,
                    java.io.DataOutput os)
             throws java.io.IOException
Description copied from interface: WireFormat
Stream based marshaling

Specified by:
marshal in interface WireFormat
Throws:
java.io.IOException

unmarshal

public java.lang.Object unmarshal(java.io.DataInput in)
                           throws java.io.IOException
Description copied from interface: WireFormat
Packet based un-marshaling

Specified by:
unmarshal in interface WireFormat
Throws:
java.io.IOException

parseAction

protected java.lang.String parseAction(java.io.DataInput in)
                                throws java.io.IOException
Throws:
java.io.IOException

parseHeaders

protected java.util.HashMap<java.lang.String,java.lang.String> parseHeaders(java.io.DataInput in)
                                                                     throws java.io.IOException
Throws:
java.io.IOException

parseContentLength

protected int parseContentLength(java.lang.String contentLength)
                          throws ProtocolException
Throws:
ProtocolException

getVersion

public int getVersion()
Specified by:
getVersion in interface WireFormat
Returns:
the version of the wire format

setVersion

public void setVersion(int version)
Specified by:
setVersion in interface WireFormat


Copyright © 2005-2011. All Rights Reserved.