Package com.rabbitmq.client.impl
Class ValueWriter
- java.lang.Object
-
- com.rabbitmq.client.impl.ValueWriter
-
public class ValueWriter extends java.lang.Object
Helper class to generate AMQP wire-protocol encoded values.
-
-
Field Summary
Fields Modifier and Type Field Description private static int
COPY_BUFFER_SIZE
private java.io.DataOutputStream
out
-
Constructor Summary
Constructors Constructor Description ValueWriter(java.io.DataOutputStream out)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description private static void
copy(java.io.InputStream input, java.io.OutputStream output)
void
flush()
Public API - call this to ensure all accumulated values are correctly written to the output stream.void
writeArray(java.lang.Object[] value)
void
writeArray(java.util.List<?> value)
void
writeFieldValue(java.lang.Object value)
void
writeLong(int l)
Public API - encodes an integer.void
writeLonglong(long ll)
Public API - encodes a long integer.void
writeLongstr(LongString str)
Public API - encodes a long string from a LongString.void
writeLongstr(java.lang.String str)
Public API - encodes a long string from a String.void
writeOctet(byte octet)
Public API - encodes an octet from a byte.void
writeOctet(int octet)
Public API - encodes an octet from an int.void
writeShort(int s)
Public API - encodes a short integer.void
writeShortstr(java.lang.String str)
Public API - encodes a short string.void
writeTable(java.util.Map<java.lang.String,java.lang.Object> table)
Public API - encodes a table.void
writeTimestamp(java.util.Date timestamp)
Public API - encodes a timestamp.
-
-
-
Field Detail
-
out
private final java.io.DataOutputStream out
-
COPY_BUFFER_SIZE
private static final int COPY_BUFFER_SIZE
- See Also:
- Constant Field Values
-
-
Method Detail
-
writeShortstr
public final void writeShortstr(java.lang.String str) throws java.io.IOException
Public API - encodes a short string.- Throws:
java.io.IOException
-
writeLongstr
public final void writeLongstr(LongString str) throws java.io.IOException
Public API - encodes a long string from a LongString.- Throws:
java.io.IOException
-
copy
private static void copy(java.io.InputStream input, java.io.OutputStream output) throws java.io.IOException
- Throws:
java.io.IOException
-
writeLongstr
public final void writeLongstr(java.lang.String str) throws java.io.IOException
Public API - encodes a long string from a String.- Throws:
java.io.IOException
-
writeShort
public final void writeShort(int s) throws java.io.IOException
Public API - encodes a short integer.- Throws:
java.io.IOException
-
writeLong
public final void writeLong(int l) throws java.io.IOException
Public API - encodes an integer.- Throws:
java.io.IOException
-
writeLonglong
public final void writeLonglong(long ll) throws java.io.IOException
Public API - encodes a long integer.- Throws:
java.io.IOException
-
writeTable
public final void writeTable(java.util.Map<java.lang.String,java.lang.Object> table) throws java.io.IOException
Public API - encodes a table.- Throws:
java.io.IOException
-
writeFieldValue
public final void writeFieldValue(java.lang.Object value) throws java.io.IOException
- Throws:
java.io.IOException
-
writeArray
public final void writeArray(java.util.List<?> value) throws java.io.IOException
- Throws:
java.io.IOException
-
writeArray
public final void writeArray(java.lang.Object[] value) throws java.io.IOException
- Throws:
java.io.IOException
-
writeOctet
public final void writeOctet(int octet) throws java.io.IOException
Public API - encodes an octet from an int.- Throws:
java.io.IOException
-
writeOctet
public final void writeOctet(byte octet) throws java.io.IOException
Public API - encodes an octet from a byte.- Throws:
java.io.IOException
-
writeTimestamp
public final void writeTimestamp(java.util.Date timestamp) throws java.io.IOException
Public API - encodes a timestamp.- Throws:
java.io.IOException
-
flush
public void flush() throws java.io.IOException
Public API - call this to ensure all accumulated values are correctly written to the output stream.- Throws:
java.io.IOException
-
-