public class StompCodec extends Object
Constructor and Description |
---|
StompCodec(org.apache.activemq.transport.tcp.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(org.apache.activemq.transport.tcp.TcpTransport transport)
public void parse(ByteArrayInputStream input, int readSize) throws Exception
Exception
protected void processCommand() throws Exception
Exception
public static String detectVersion(Map<String,String> headers) throws ProtocolException
ProtocolException
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.