public class AmqpFrameParser extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
AmqpFrameParser.AMQPFrameSink |
Constructor and Description |
---|
AmqpFrameParser(AmqpFrameParser.AMQPFrameSink sink) |
AmqpFrameParser(org.apache.activemq.transport.tcp.TcpTransport transport) |
Modifier and Type | Method and Description |
---|---|
AmqpWireFormat |
getWireFormat() |
void |
parse(ByteBuffer incoming) |
void |
reset() |
void |
setWireFormat(AmqpWireFormat wireFormat) |
public AmqpFrameParser(AmqpFrameParser.AMQPFrameSink sink)
public AmqpFrameParser(org.apache.activemq.transport.tcp.TcpTransport transport)
public void parse(ByteBuffer incoming) throws Exception
Exception
public void reset()
public void setWireFormat(AmqpWireFormat wireFormat)
public AmqpWireFormat getWireFormat()
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.