org.apache.activemq.transport.amqp

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 and Description
static interface	AmqpFrameParser.AMQPFrameSink

Constructor Summary

Constructors

Constructor and Description
AmqpFrameParser(AmqpFrameParser.AMQPFrameSink sink)
AmqpFrameParser(TcpTransport transport)

Method Summary

Methods

Modifier and Type	Method and Description
AmqpWireFormat	getWireFormat()
void	parse(ByteBuffer incoming)
void	reset()
void	setWireFormat(AmqpWireFormat wireFormat)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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()