Class AmqpFrameParser
- java.lang.Object
-
- org.apache.activemq.transport.amqp.AmqpFrameParser
-
public class AmqpFrameParser extends Object
State based Frame reader that is used in the NIO based transports where AMQP frames can come in in partial or overlapping forms.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
AmqpFrameParser.AMQPFrameSink
-
Constructor Summary
Constructors Constructor Description AmqpFrameParser(AmqpFrameParser.AMQPFrameSink sink)
AmqpFrameParser(TcpTransport transport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AmqpWireFormat
getWireFormat()
void
parse(ByteBuffer incoming)
void
reset()
void
setWireFormat(AmqpWireFormat wireFormat)
-
-
-
Constructor Detail
-
AmqpFrameParser
public AmqpFrameParser(AmqpFrameParser.AMQPFrameSink sink)
-
AmqpFrameParser
public AmqpFrameParser(TcpTransport transport)
-
-
Method Detail
-
parse
public void parse(ByteBuffer incoming) throws Exception
- Throws:
Exception
-
reset
public void reset()
-
setWireFormat
public void setWireFormat(AmqpWireFormat wireFormat)
-
getWireFormat
public AmqpWireFormat getWireFormat()
-
-