Package com.rabbitmq.client.impl
Class ContentHeaderPropertyReader
- java.lang.Object
-
- com.rabbitmq.client.impl.ContentHeaderPropertyReader
-
public class ContentHeaderPropertyReader extends Object
Parses an AMQP wire-protocolContentHeader
from a DataInputStream. Methods on this object are usually called from autogenerated code.
-
-
Constructor Summary
Constructors Constructor Description ContentHeaderPropertyReader(DataInputStream in)
Protected API - Constructs a reader from the given input stream
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.
-
-
-
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
-
-