Package com.rabbitmq.client.impl
Class ContentHeaderPropertyReader
java.lang.Object
com.rabbitmq.client.impl.ContentHeaderPropertyReader
Parses an AMQP wire-protocol
ContentHeader
from a
DataInputStream. Methods on this object are usually called from
autogenerated code.-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate int
Current flag position counterprivate int
Current field flag wordprivate final ValueReader
Stream we are reading from -
Constructor Summary
ConstructorsConstructorDescriptionProtected API - Constructs a reader from the given input stream -
Method Summary
Modifier and TypeMethodDescriptionvoid
private boolean
void
readLong()
Reads and returns an AMQP integer content header field.Reads and returns an AMQP long integer content header field.Reads and returns an AMQP "long string" (binary) content header field.int
Reads and returns an AMQP octet content header field.boolean
Reads and returns an AMQP short integer content header field.Reads and returns an AMQP short string content header field.Reads and returns an AMQP table content header field.Reads and returns an AMQP timestamp content header field.
-
Field Details
-
in
Stream we are reading from -
flagWord
private int flagWordCurrent field flag word -
bitCount
private int bitCountCurrent flag position counter
-
-
Constructor Details
-
ContentHeaderPropertyReader
Protected API - Constructs a reader from the given input stream- Throws:
IOException
-
-
Method Details
-
isContinuationBitSet
private boolean isContinuationBitSet() -
readFlagWord
- Throws:
IOException
-
readPresence
- Throws:
IOException
-
finishPresence
- Throws:
IOException
-
readShortstr
Reads and returns an AMQP short string content header field.- Throws:
IOException
-
readLongstr
Reads and returns an AMQP "long string" (binary) content header field.- Throws:
IOException
-
readShort
Reads and returns an AMQP short integer content header field.- Throws:
IOException
-
readLong
Reads and returns an AMQP integer content header field.- Throws:
IOException
-
readLonglong
Reads and returns an AMQP long integer content header field.- Throws:
IOException
-
readTable
Reads and returns an AMQP table content header field.- Throws:
IOException
-
readOctet
Reads and returns an AMQP octet content header field.- Throws:
IOException
-
readTimestamp
Reads and returns an AMQP timestamp content header field.- Throws:
IOException
-