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.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	finishPresence()
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

Constructor Detail

ContentHeaderPropertyReader

public ContentHeaderPropertyReader(DataInputStream in)
                            throws IOException

Protected API - Constructs a reader from the given input stream

Throws:

IOException

Method Detail

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