Package com.rabbitmq.client.impl

Class MethodArgumentWriter

java.lang.Object

com.rabbitmq.client.impl.MethodArgumentWriter

public class MethodArgumentWriter
extends java.lang.Object

Generates AMQP wire-protocol encoded arguments. Methods on this object are usually called from autogenerated code.

Field Summary

Fields

Modifier and Type	Field	Description
private byte	bitAccumulator	The current group of bits
private int	bitMask	The current position within the group of bits
private boolean	needBitFlush	When encoding one or more bits, records whether a group of bits is waiting to be written
private ValueWriter	out	Writes our output

Constructor Summary

Constructors

Constructor	Description
MethodArgumentWriter(ValueWriter out)	Constructs a MethodArgumentWriter targeting the given DataOutputStream.

Method Summary

Modifier and Type	Method	Description
private void	bitflush()	Private API - called when we may be transitioning from encoding a group of bits to encoding a non-bit value.
void	flush()	Public API - call this to ensure all accumulated argument values are correctly written to the output stream.
private void	resetBitAccumulator()	Private API - called to reset the bit group variables.
void	writeBit(boolean b)	Public API - encodes a boolean/bit argument.
void	writeLong(int l)	Public API - encodes an integer argument.
void	writeLonglong(long ll)	Public API - encodes a long integer argument.
void	writeLongstr(LongString str)	Public API - encodes a long string argument from a LongString.
void	writeLongstr(java.lang.String str)	Public API - encodes a long string argument from a String.
void	writeOctet(byte octet)	Public API - encodes an octet argument from a byte.
void	writeOctet(int octet)	Public API - encodes an octet argument from an int.
void	writeShort(int s)	Public API - encodes a short integer argument.
void	writeShortstr(java.lang.String str)	Public API - encodes a short string argument.
void	writeTable(java.util.Map<java.lang.String,java.lang.Object> table)	Public API - encodes a table argument.
void	writeTimestamp(java.util.Date timestamp)	Public API - encodes a timestamp argument.

Methods inherited from class java.lang.Object

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

Field Detail

out

private final ValueWriter out

Writes our output

needBitFlush

private boolean needBitFlush

When encoding one or more bits, records whether a group of bits is waiting to be written

bitAccumulator

private byte bitAccumulator

The current group of bits

bitMask

private int bitMask

The current position within the group of bits

Constructor Detail

MethodArgumentWriter

public MethodArgumentWriter(ValueWriter out)

Constructs a MethodArgumentWriter targeting the given DataOutputStream.

Method Detail

resetBitAccumulator

private void resetBitAccumulator()

Private API - called to reset the bit group variables.

bitflush

private final void bitflush()
                     throws java.io.IOException

Private API - called when we may be transitioning from encoding a group of bits to encoding a non-bit value.

Throws:

java.io.IOException

writeShortstr

public final void writeShortstr(java.lang.String str)
                         throws java.io.IOException

Public API - encodes a short string argument.

Throws:

java.io.IOException

writeLongstr

public final void writeLongstr(LongString str)
                        throws java.io.IOException

Public API - encodes a long string argument from a LongString.

Throws:

java.io.IOException

writeLongstr

public final void writeLongstr(java.lang.String str)
                        throws java.io.IOException

Public API - encodes a long string argument from a String.

Throws:

java.io.IOException

writeShort

public final void writeShort(int s)
                      throws java.io.IOException

Public API - encodes a short integer argument.

Throws:

java.io.IOException

writeLong

public final void writeLong(int l)
                     throws java.io.IOException

Public API - encodes an integer argument.

Throws:

java.io.IOException

writeLonglong

public final void writeLonglong(long ll)
                         throws java.io.IOException

Public API - encodes a long integer argument.

Throws:

java.io.IOException

writeBit

public final void writeBit(boolean b)
                    throws java.io.IOException

Public API - encodes a boolean/bit argument.

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 argument.

Throws:

java.io.IOException

writeOctet

public final void writeOctet(int octet)
                      throws java.io.IOException

Public API - encodes an octet argument from an int.

Throws:

java.io.IOException

writeOctet

public final void writeOctet(byte octet)
                      throws java.io.IOException

Public API - encodes an octet argument 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 argument.

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException

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

Throws:

java.io.IOException