public class AMQPInputStream extends Object
Modifier and Type | Field and Description |
---|---|
private int |
bit
If we are reading one or more bits, keeps track of which bit position we
are reading from
|
private int |
bits
If we are reading one or more bits, holds the current packed collection of
bits
|
private InputStream |
in |
static org.objectweb.util.monolog.api.Logger |
logger |
Constructor and Description |
---|
AMQPInputStream(InputStream inputStream) |
Modifier and Type | Method and Description |
---|---|
private void |
clearBits() |
private Object[] |
readArray() |
boolean |
readBit() |
boolean |
readBoolean() |
private Object |
readFieldValue() |
int |
readLong() |
long |
readLonglong() |
LongString |
readLongstr() |
int |
readOctet() |
int |
readShort() |
String |
readShortstr() |
Map |
readTable() |
Date |
readTimestamp() |
public static org.objectweb.util.monolog.api.Logger logger
private InputStream in
private int bits
private int bit
public AMQPInputStream(InputStream inputStream)
private void clearBits()
public final String readShortstr() throws IOException
IOException
public final LongString readLongstr() throws IOException
IOException
public final int readShort() throws IOException
IOException
public final int readLong() throws IOException
IOException
public final long readLonglong() throws IOException
IOException
public final boolean readBoolean() throws IOException
IOException
public final boolean readBit() throws IOException
IOException
private final Object readFieldValue() throws IOException, SyntaxErrorException
IOException
SyntaxErrorException
public final Map readTable() throws IOException, SyntaxErrorException
IOException
SyntaxErrorException
private final Object[] readArray() throws IOException, SyntaxErrorException
IOException
SyntaxErrorException
public final int readOctet() throws IOException
IOException
public final Date readTimestamp() throws IOException
IOException
Copyright © 2016 ScalAgent D.T.. All Rights Reserved.