Package com.rabbitmq.client.impl

Class ValueWriter

java.lang.Object

com.rabbitmq.client.impl.ValueWriter

public class ValueWriter
extends Object

Helper class to generate AMQP wire-protocol encoded values.

Constructor Summary

Constructors

Constructor	Description
ValueWriter(DataOutputStream out)

Method Summary

Modifier and Type	Method	Description
void	flush()	Public API - call this to ensure all accumulated values are correctly written to the output stream.
final void	writeArray(Object[] value)
final void	writeArray(List<?> value)
final void	writeFieldValue(Object value)
final void	writeLong(int l)	Public API - encodes an integer.
final void	writeLonglong(long ll)	Public API - encodes a long integer.
final void	writeLongstr(LongString str)	Public API - encodes a long string from a LongString.
final void	writeLongstr(String str)	Public API - encodes a long string from a String.
final void	writeOctet(byte octet)	Public API - encodes an octet from a byte.
final void	writeOctet(int octet)	Public API - encodes an octet from an int.
final void	writeShort(int s)	Public API - encodes a short integer.
final void	writeShortstr(String str)	Public API - encodes a short string.
final void	writeTable(Map<String,Object> table)	Public API - encodes a table.
final void	writeTimestamp(Date timestamp)	Public API - encodes a timestamp.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ValueWriter

public ValueWriter(DataOutputStream out)

Method Details

writeShortstr

public final void writeShortstr(String str)
                         throws IOException

Public API - encodes a short string.

Throws:

IOException

writeLongstr

public final void writeLongstr(LongString str)
                        throws IOException

Public API - encodes a long string from a LongString.

Throws:

IOException

writeLongstr

public final void writeLongstr(String str)
                        throws IOException

Public API - encodes a long string from a String.

Throws:

IOException

writeShort

public final void writeShort(int s)
                      throws IOException

Public API - encodes a short integer.

Throws:

IOException

writeLong

public final void writeLong(int l)
                     throws IOException

Public API - encodes an integer.

Throws:

IOException

writeLonglong

public final void writeLonglong(long ll)
                         throws IOException

Public API - encodes a long integer.

Throws:

IOException

writeTable

public final void writeTable(Map<String,Object> table)
                      throws IOException

Public API - encodes a table.

Throws:

IOException

writeFieldValue

public final void writeFieldValue(Object value)
                           throws IOException

Throws:

IOException

writeArray

public final void writeArray(List<?> value)
                      throws IOException

Throws:

IOException

writeArray

public final void writeArray(Object[] value)
                      throws IOException

Throws:

IOException

writeOctet

public final void writeOctet(int octet)
                      throws IOException

Public API - encodes an octet from an int.

Throws:

IOException

writeOctet

public final void writeOctet(byte octet)
                      throws IOException

Public API - encodes an octet from a byte.

Throws:

IOException

writeTimestamp

public final void writeTimestamp(Date timestamp)
                          throws IOException

Public API - encodes a timestamp.

Throws:

IOException

flush

public void flush()
           throws IOException

Public API - call this to ensure all accumulated values are correctly written to the output stream.

Throws:

IOException