Class StompCodec
- java.lang.Object
-
- org.apache.activemq.transport.stomp.StompCodec
-
public class StompCodec extends Object
-
-
Constructor Summary
Constructors Constructor Description StompCodec(TcpTransport transport)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static String
detectVersion(Map<String,String> headers)
void
parse(ByteArrayInputStream input, int readSize)
protected void
processCommand()
-
-
-
Constructor Detail
-
StompCodec
public StompCodec(TcpTransport transport)
-
-
Method Detail
-
parse
public void parse(ByteArrayInputStream input, int readSize) throws Exception
- Throws:
Exception
-
detectVersion
public static String detectVersion(Map<String,String> headers) throws ProtocolException
- Throws:
ProtocolException
-
-