public class AMQPOutputStream extends Object
Modifier and Type | Field and Description |
---|---|
private byte |
bitAccumulator |
private int |
bitMask |
private int |
DEFAULT_BUFFER_SIZE |
static Logger |
logger |
private boolean |
needBitFlush |
private OutputStream |
out |
Constructor and Description |
---|
AMQPOutputStream(OutputStream outputStream) |
Modifier and Type | Method and Description |
---|---|
private int |
arraySize(Object[] value) |
private void |
bitflush() |
private long |
fieldValueSize(Object value) |
private int |
shortStrSize(String str) |
private long |
tableSize(Map table) |
private void |
writeArray(Object[] array) |
void |
writeBit(boolean b) |
void |
writeBoolean(boolean b) |
void |
writeByte(byte b) |
void |
writeDouble(double doubleValue) |
private void |
writeFieldValue(Object value) |
void |
writeFloat(float floatValue) |
void |
writeLong(int l) |
void |
writeLonglong(long l) |
void |
writeLongstr(LongString str) |
void |
writeOctet(byte octet) |
void |
writeOctet(int octet) |
void |
writeShort(int s) |
void |
writeShort(short s) |
void |
writeShortstr(String str) |
void |
writeTable(Map table) |
void |
writeTimestamp(Date timestamp) |
public static Logger logger
private final int DEFAULT_BUFFER_SIZE
private boolean needBitFlush
private byte bitAccumulator
private int bitMask
private OutputStream out
public AMQPOutputStream(OutputStream outputStream)
public final void writeShortstr(String str) throws IOException
IOException
public final void writeLongstr(LongString str) throws IOException
IOException
public final void writeShort(short s) throws IOException
IOException
public final void writeShort(int s) throws IOException
IOException
public final void writeLong(int l) throws IOException
IOException
public final void writeLonglong(long l) throws IOException
IOException
public final void writeByte(byte b) throws IOException
IOException
private final void bitflush() throws IOException
IOException
public final void writeBit(boolean b) throws IOException
IOException
public final void writeBoolean(boolean b) throws IOException
IOException
public final void writeTable(Map table) throws IOException
IOException
private void writeFieldValue(Object value) throws IOException
IOException
private void writeArray(Object[] array) throws IOException
IOException
public final void writeFloat(float floatValue) throws IOException
IOException
public final void writeDouble(double doubleValue) throws IOException
IOException
public final void writeOctet(int octet) throws IOException
IOException
public final void writeOctet(byte octet) throws IOException
IOException
public final void writeTimestamp(Date timestamp) throws IOException
IOException
private int shortStrSize(String str) throws UnsupportedEncodingException
UnsupportedEncodingException
private long tableSize(Map table) throws UnsupportedEncodingException
UnsupportedEncodingException
private long fieldValueSize(Object value) throws UnsupportedEncodingException
UnsupportedEncodingException
private int arraySize(Object[] value) throws UnsupportedEncodingException
UnsupportedEncodingException
Copyright © 2023 ScalAgent D.T.. All rights reserved.