Class ByteArrayEncodedMessage

java.lang.Object

com.rabbitmq.stream.codec.ByteArrayEncodedMessage

All Implemented Interfaces:

Codec.EncodedMessage

public final class ByteArrayEncodedMessage
extends Object
implements Codec.EncodedMessage

Constructor Summary

Constructors

Constructor	Description
ByteArrayEncodedMessage(int size, byte[] data)

Method Summary

Modifier and Type	Method	Description
int	getSize()
void	writeTo(ByteBuf buf)	Use for outbound, uncompressed messages.
void	writeTo(OutputStream outputStream)	Used for outbound, compressed messages.

Methods inherited from class Object

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

Constructor Details

ByteArrayEncodedMessage

public ByteArrayEncodedMessage(int size,
 byte[] data)

Method Details

writeTo

public void writeTo(OutputStream outputStream)
             throws IOException

Description copied from interface: Codec.EncodedMessage

Used for outbound, compressed messages.

Specified by:

writeTo in interface Codec.EncodedMessage

Parameters:

outputStream -

Throws:

IOException

writeTo

public void writeTo(ByteBuf buf)

Description copied from interface: Codec.EncodedMessage

Use for outbound, uncompressed messages.

Specified by:

writeTo in interface Codec.EncodedMessage

Parameters:

buf -

getSize

public int getSize()

Specified by:

getSize in interface Codec.EncodedMessage