Package com.rabbitmq.client.impl

Class ContentHeaderPropertyReader

java.lang.Object

com.rabbitmq.client.impl.ContentHeaderPropertyReader

public class ContentHeaderPropertyReader
extends Object

Parses an AMQP wire-protocol ContentHeader from a DataInputStream. Methods on this object are usually called from autogenerated code.

Field Summary

Fields

Modifier and Type	Field	Description
private int	bitCount	Current flag position counter
private int	flagWord	Current field flag word
private final ValueReader	in	Stream we are reading from

Constructor Summary

Constructors

Constructor	Description
ContentHeaderPropertyReader(DataInputStream in)	Protected API - Constructs a reader from the given input stream

Method Summary

Modifier and Type	Method	Description
void	finishPresence()
private boolean	isContinuationBitSet()
void	readFlagWord()
Integer	readLong()	Reads and returns an AMQP integer content header field.
Long	readLonglong()	Reads and returns an AMQP long integer content header field.
LongString	readLongstr()	Reads and returns an AMQP "long string" (binary) content header field.
int	readOctet()	Reads and returns an AMQP octet content header field.
boolean	readPresence()
Integer	readShort()	Reads and returns an AMQP short integer content header field.
String	readShortstr()	Reads and returns an AMQP short string content header field.
Map<String,Object>	readTable()	Reads and returns an AMQP table content header field.
Date	readTimestamp()	Reads and returns an AMQP timestamp content header field.

Methods inherited from class java.lang.Object

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

Field Details

in

private final ValueReader in

Stream we are reading from

flagWord

private int flagWord

Current field flag word

bitCount

private int bitCount

Current flag position counter

Constructor Details

ContentHeaderPropertyReader

public ContentHeaderPropertyReader(DataInputStream in)
                            throws IOException

Protected API - Constructs a reader from the given input stream

Throws:

IOException

Method Details

isContinuationBitSet

private boolean isContinuationBitSet()

readFlagWord

public void readFlagWord()
                  throws IOException

Throws:

IOException

readPresence

public boolean readPresence()
                     throws IOException

Throws:

IOException

finishPresence

public void finishPresence()
                    throws IOException

Throws:

IOException

readShortstr

public String readShortstr()
                    throws IOException

Reads and returns an AMQP short string content header field.

Throws:

IOException

readLongstr

public LongString readLongstr()
                       throws IOException

Reads and returns an AMQP "long string" (binary) content header field.

Throws:

IOException

readShort

public Integer readShort()
                  throws IOException

Reads and returns an AMQP short integer content header field.

Throws:

IOException

readLong

public Integer readLong()
                 throws IOException

Reads and returns an AMQP integer content header field.

Throws:

IOException

readLonglong

public Long readLonglong()
                  throws IOException

Reads and returns an AMQP long integer content header field.

Throws:

IOException

readTable

public Map<String,Object> readTable()
                             throws IOException

Reads and returns an AMQP table content header field.

Throws:

IOException

readOctet

public int readOctet()
              throws IOException

Reads and returns an AMQP octet content header field.

Throws:

IOException

readTimestamp

public Date readTimestamp()
                   throws IOException

Reads and returns an AMQP timestamp content header field.

Throws:

IOException