org.apache.activemq.transport.stomp
Class StompCodec

java.lang.Object
  extended by org.apache.activemq.transport.stomp.StompCodec

public class StompCodec
extends Object


Constructor Summary
StompCodec(TcpTransport transport)
           
 
Method Summary
static String detectVersion(Map<String,String> headers)
           
 void parse(ByteArrayInputStream input, int readSize)
           
protected  void processCommand()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StompCodec

public StompCodec(TcpTransport transport)
Method Detail

parse

public void parse(ByteArrayInputStream input,
                  int readSize)
           throws Exception
Throws:
Exception

processCommand

protected void processCommand()
                       throws Exception
Throws:
Exception

detectVersion

public static String detectVersion(Map<String,String> headers)
                            throws ProtocolException
Throws:
ProtocolException


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.