public class StompCodec extends Object
| Constructor and Description |
|---|
StompCodec(TcpTransport transport) |
| Modifier and Type | Method and Description |
|---|---|
static String |
detectVersion(Map<String,String> headers) |
void |
parse(ByteArrayInputStream input,
int readSize) |
protected void |
processCommand() |
public StompCodec(TcpTransport transport)
public void parse(ByteArrayInputStream input, int readSize) throws Exception
Exceptionprotected void processCommand() throws Exception
Exceptionpublic static String detectVersion(Map<String,String> headers) throws ProtocolException
ProtocolExceptionCopyright © 2005–2015 FuseSource, Corp.. All rights reserved.