org.apache.activemq.artemis.core.client.impl

Class LargeMessageControllerImpl

java.lang.Object

org.apache.activemq.artemis.core.client.impl.LargeMessageControllerImpl

All Implemented Interfaces:

DataInput, org.apache.activemq.artemis.api.core.ActiveMQBuffer, LargeMessageController

public class LargeMessageControllerImpl
extends Object
implements LargeMessageController

This class aggregates several SessionReceiveContinuationMessage as it was being handled by a single buffer. This buffer can be consumed as messages are arriving, and it will hold the packets until they are read using the ChannelBuffer interface, or the setOutputStream or saveStream are called.

Constructor Summary

Constructors

Constructor and Description
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout)
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout, File cachedFile)
LargeMessageControllerImpl(ClientConsumerInternal consumerInternal, long totalSize, long readTimeout, File cachedFile, int bufferSize)

Method Summary

Modifier and Type	Method and Description
void	addPacket(byte[] chunk, int flowControlSize, boolean isContinues) TODO: move this to ConsumerContext as large message is a protocol specific thing Add a buff to the List, or save it to the OutputStream if set
io.netty.buffer.ByteBuf	byteBuf()
void	cancel() Cancels this buffer.
int	capacity()
void	clear()
void	close() Closes this buffer.
org.apache.activemq.artemis.api.core.ActiveMQBuffer	copy()
org.apache.activemq.artemis.api.core.ActiveMQBuffer	copy(int index, int length)
void	discardReadBytes()
void	discardUnusedPackets() Discards packets unused by this buffer.
org.apache.activemq.artemis.api.core.ActiveMQBuffer	duplicate()
byte	getByte(int index)
void	getBytes(int index, org.apache.activemq.artemis.api.core.ActiveMQBuffer dst)
void	getBytes(int index, org.apache.activemq.artemis.api.core.ActiveMQBuffer dst, int length)
void	getBytes(int index, org.apache.activemq.artemis.api.core.ActiveMQBuffer dst, int dstIndex, int length)
void	getBytes(int index, byte[] dst)
void	getBytes(int index, byte[] dst, int dstIndex, int length)
void	getBytes(int index, ByteBuffer dst)
int	getBytes(int index, GatheringByteChannel out, int length)
void	getBytes(int index, OutputStream out, int length)
void	getBytes(long index, byte[] dst)
void	getBytes(long index, byte[] dst, int dstIndex, int length)
void	getBytes(long index, ByteBuffer dst)
void	getBytes(long index, OutputStream out, int length)
char	getChar(int index)
double	getDouble(int index)
float	getFloat(int index)
int	getInt(int index)
int	getInt(long index)
long	getLong(int index)
long	getLong(long index)
int	getMedium(int index)
short	getShort(int index)
short	getShort(long index)
long	getSize() Returns the size of this buffer.
Object	getUnderlyingBuffer()
short	getUnsignedByte(int index)
long	getUnsignedInt(int index)
int	getUnsignedMedium(long index)
int	getUnsignedShort(int index)
void	markReaderIndex()
void	markWriterIndex()
boolean	readable()
int	readableBytes()
boolean	readBoolean()
byte	readByte()
void	readBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer dst)
void	readBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer dst, int length)
void	readBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer dst, int dstIndex, int length)
void	readBytes(byte[] dst)
void	readBytes(byte[] dst, int dstIndex, int length)
void	readBytes(ByteBuffer dst)
int	readBytes(GatheringByteChannel out, int length)
org.apache.activemq.artemis.api.core.ActiveMQBuffer	readBytes(int length)
void	readBytes(OutputStream out, int length)
char	readChar()
double	readDouble()
int	readerIndex()
void	readerIndex(int readerIndex)
float	readFloat()
void	readFully(byte[] b) from DataInput interface
void	readFully(byte[] b, int off, int len) from DataInput interface
int	readInt()
int	readInt(int pos)
String	readLine() from DataInput interface
long	readLong()
int	readMedium()
org.apache.activemq.artemis.api.core.SimpleString	readNullableSimpleString()
String	readNullableString()
short	readShort()
org.apache.activemq.artemis.api.core.SimpleString	readSimpleString()
org.apache.activemq.artemis.api.core.ActiveMQBuffer	readSlice(int length)
String	readString()
int	readUnsignedByte()
long	readUnsignedInt()
int	readUnsignedMedium()
int	readUnsignedShort()
String	readUTF()
void	resetReaderIndex()
void	resetWriterIndex()
void	saveBuffer(OutputStream output) Saves this buffer to the specified output.
void	setByte(int index, byte value)
void	setBytes(int index, org.apache.activemq.artemis.api.core.ActiveMQBuffer src)
void	setBytes(int index, org.apache.activemq.artemis.api.core.ActiveMQBuffer src, int length)
void	setBytes(int index, org.apache.activemq.artemis.api.core.ActiveMQBuffer src, int srcIndex, int length)
void	setBytes(int index, byte[] src)
void	setBytes(int index, byte[] src, int srcIndex, int length)
void	setBytes(int index, ByteBuffer src)
void	setChar(int index, char value)
void	setDouble(int index, double value)
void	setFloat(int index, float value)
void	setIndex(int readerIndex, int writerIndex)
void	setInt(int index, int value)
void	setLocal(boolean local)
void	setLong(int index, long value)
void	setOutputStream(OutputStream output) Sets the OutputStream of this buffer to the specified output.
void	setShort(int index, short value)
void	setZero(int index, int length)
int	skipBytes(int length)
org.apache.activemq.artemis.api.core.ActiveMQBuffer	slice()
org.apache.activemq.artemis.api.core.ActiveMQBuffer	slice(int index, int length)
ByteBuffer	toByteBuffer()
ByteBuffer	toByteBuffer(int index, int length)
ByteBuffer[]	toByteBuffers()
ByteBuffer[]	toByteBuffers(int index, int length)
String	toString(String charsetName)
boolean	waitCompletion(long timeWait) Waits for the completion for the specified waiting time (in milliseconds).
boolean	writable()
int	writableBytes()
void	writeBoolean(boolean val)
void	writeByte(byte value)
void	writeBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer src)
void	writeBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer src, int length)
void	writeBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer src, int srcIndex, int length)
void	writeBytes(byte[] src)
void	writeBytes(byte[] src, int srcIndex, int length)
void	writeBytes(ByteBuffer src)
int	writeBytes(InputStream in, int length)
int	writeBytes(ScatteringByteChannel in, int length)
void	writeChar(char val)
void	writeDouble(double val)
void	writeFloat(float val)
void	writeInt(int value)
void	writeLong(long value)
void	writeMedium(int value)
void	writeNullableSimpleString(org.apache.activemq.artemis.api.core.SimpleString val)
void	writeNullableString(String val)
int	writerIndex()
void	writerIndex(int writerIndex)
void	writeShort(short value)
void	writeSimpleString(org.apache.activemq.artemis.api.core.SimpleString val)
void	writeString(String val)
void	writeUTF(String utf)
void	writeZero(int length)

Methods inherited from class java.lang.Object

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

Constructor Detail

LargeMessageControllerImpl

public LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
                                  long totalSize,
                                  long readTimeout)

LargeMessageControllerImpl

public LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
                                  long totalSize,
                                  long readTimeout,
                                  File cachedFile)

LargeMessageControllerImpl

public LargeMessageControllerImpl(ClientConsumerInternal consumerInternal,
                                  long totalSize,
                                  long readTimeout,
                                  File cachedFile,
                                  int bufferSize)

Method Detail

setLocal

public void setLocal(boolean local)

discardUnusedPackets

public void discardUnusedPackets()

Description copied from interface: LargeMessageController

Discards packets unused by this buffer.

Specified by:

discardUnusedPackets in interface LargeMessageController

addPacket

public void addPacket(byte[] chunk,
                      int flowControlSize,
                      boolean isContinues)

TODO: move this to ConsumerContext as large message is a protocol specific thing Add a buff to the List, or save it to the OutputStream if set

Specified by:

addPacket in interface LargeMessageController

cancel

public void cancel()

Description copied from interface: LargeMessageController

Cancels this buffer.

Specified by:

cancel in interface LargeMessageController

close

public void close()

Description copied from interface: LargeMessageController

Closes this buffer.

Specified by:

close in interface LargeMessageController

setOutputStream

public void setOutputStream(OutputStream output)
                     throws org.apache.activemq.artemis.api.core.ActiveMQException

Description copied from interface: LargeMessageController

Sets the OutputStream of this buffer to the specified output.

Specified by:

setOutputStream in interface LargeMessageController

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

saveBuffer

public void saveBuffer(OutputStream output)
                throws org.apache.activemq.artemis.api.core.ActiveMQException

Description copied from interface: LargeMessageController

Saves this buffer to the specified output. This is just a blocking version of LargeMessageController.setOutputStream(OutputStream).

Specified by:

saveBuffer in interface LargeMessageController

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

waitCompletion

public boolean waitCompletion(long timeWait)
                       throws org.apache.activemq.artemis.api.core.ActiveMQException

Description copied from interface: LargeMessageController

Waits for the completion for the specified waiting time (in milliseconds).

Specified by:

waitCompletion in interface LargeMessageController

Parameters:

timeWait - Milliseconds to Wait. 0 means forever

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

capacity

public int capacity()

Specified by:

capacity in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readByte

public byte readByte()

Specified by:

readByte in interface DataInput

Specified by:

readByte in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getByte

public byte getByte(int index)

Specified by:

getByte in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getBytes

public void getBytes(int index,
                     org.apache.activemq.artemis.api.core.ActiveMQBuffer dst,
                     int dstIndex,
                     int length)

Specified by:

getBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getBytes

public void getBytes(int index,
                     byte[] dst,
                     int dstIndex,
                     int length)

Specified by:

getBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getBytes

public void getBytes(long index,
                     byte[] dst,
                     int dstIndex,
                     int length)

getBytes

public void getBytes(int index,
                     ByteBuffer dst)

Specified by:

getBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getBytes

public void getBytes(long index,
                     ByteBuffer dst)

getBytes

public void getBytes(int index,
                     OutputStream out,
                     int length)
              throws IOException

Throws:

IOException

getBytes

public void getBytes(long index,
                     OutputStream out,
                     int length)
              throws IOException

Throws:

IOException

getBytes

public int getBytes(int index,
                    GatheringByteChannel out,
                    int length)
             throws IOException

Throws:

IOException

getInt

public int getInt(int index)

Specified by:

getInt in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getInt

public int getInt(long index)

getLong

public long getLong(int index)

Specified by:

getLong in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getLong

public long getLong(long index)

getShort

public short getShort(int index)

Specified by:

getShort in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getShort

public short getShort(long index)

getUnsignedMedium

public int getUnsignedMedium(long index)

setByte

public void setByte(int index,
                    byte value)

Specified by:

setByte in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setBytes

public void setBytes(int index,
                     org.apache.activemq.artemis.api.core.ActiveMQBuffer src,
                     int srcIndex,
                     int length)

Specified by:

setBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setBytes

public void setBytes(int index,
                     byte[] src,
                     int srcIndex,
                     int length)

Specified by:

setBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setBytes

public void setBytes(int index,
                     ByteBuffer src)

Specified by:

setBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setInt

public void setInt(int index,
                   int value)

Specified by:

setInt in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setLong

public void setLong(int index,
                    long value)

Specified by:

setLong in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setShort

public void setShort(int index,
                     short value)

Specified by:

setShort in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

toByteBuffer

public ByteBuffer toByteBuffer(int index,
                               int length)

Specified by:

toByteBuffer in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readerIndex

public int readerIndex()

Specified by:

readerIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readerIndex

public void readerIndex(int readerIndex)

Specified by:

readerIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writerIndex

public int writerIndex()

Specified by:

writerIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getSize

public long getSize()

Description copied from interface: LargeMessageController

Returns the size of this buffer.

Specified by:

getSize in interface LargeMessageController

writerIndex

public void writerIndex(int writerIndex)

Specified by:

writerIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setIndex

public void setIndex(int readerIndex,
                     int writerIndex)

Specified by:

setIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

clear

public void clear()

Specified by:

clear in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readable

public boolean readable()

Specified by:

readable in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writable

public boolean writable()

Specified by:

writable in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readableBytes

public int readableBytes()

Specified by:

readableBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writableBytes

public int writableBytes()

Specified by:

writableBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

markReaderIndex

public void markReaderIndex()

Specified by:

markReaderIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

resetReaderIndex

public void resetReaderIndex()

Specified by:

resetReaderIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

markWriterIndex

public void markWriterIndex()

Specified by:

markWriterIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

resetWriterIndex

public void resetWriterIndex()

Specified by:

resetWriterIndex in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

discardReadBytes

public void discardReadBytes()

Specified by:

discardReadBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getUnsignedByte

public short getUnsignedByte(int index)

Specified by:

getUnsignedByte in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getUnsignedShort

public int getUnsignedShort(int index)

Specified by:

getUnsignedShort in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getMedium

public int getMedium(int index)

getUnsignedInt

public long getUnsignedInt(int index)

Specified by:

getUnsignedInt in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getBytes

public void getBytes(int index,
                     byte[] dst)

Specified by:

getBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getBytes

public void getBytes(long index,
                     byte[] dst)

getBytes

public void getBytes(int index,
                     org.apache.activemq.artemis.api.core.ActiveMQBuffer dst)

Specified by:

getBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getBytes

public void getBytes(int index,
                     org.apache.activemq.artemis.api.core.ActiveMQBuffer dst,
                     int length)

Specified by:

getBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setBytes

public void setBytes(int index,
                     byte[] src)

Specified by:

setBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setBytes

public void setBytes(int index,
                     org.apache.activemq.artemis.api.core.ActiveMQBuffer src)

Specified by:

setBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setBytes

public void setBytes(int index,
                     org.apache.activemq.artemis.api.core.ActiveMQBuffer src,
                     int length)

Specified by:

setBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setZero

public void setZero(int index,
                    int length)

readUnsignedByte

public int readUnsignedByte()

Specified by:

readUnsignedByte in interface DataInput

Specified by:

readUnsignedByte in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readShort

public short readShort()

Specified by:

readShort in interface DataInput

Specified by:

readShort in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readUnsignedShort

public int readUnsignedShort()

Specified by:

readUnsignedShort in interface DataInput

Specified by:

readUnsignedShort in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readMedium

public int readMedium()

readUnsignedMedium

public int readUnsignedMedium()

readInt

public int readInt()

Specified by:

readInt in interface DataInput

Specified by:

readInt in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readInt

public int readInt(int pos)

readUnsignedInt

public long readUnsignedInt()

Specified by:

readUnsignedInt in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readLong

public long readLong()

Specified by:

readLong in interface DataInput

Specified by:

readLong in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readBytes

public void readBytes(byte[] dst,
                      int dstIndex,
                      int length)

Specified by:

readBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readBytes

public void readBytes(byte[] dst)

Specified by:

readBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readBytes

public void readBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer dst)

Specified by:

readBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readBytes

public void readBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer dst,
                      int length)

Specified by:

readBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readBytes

public void readBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer dst,
                      int dstIndex,
                      int length)

Specified by:

readBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readBytes

public void readBytes(ByteBuffer dst)

Specified by:

readBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readBytes

public int readBytes(GatheringByteChannel out,
                     int length)
              throws IOException

Throws:

IOException

readBytes

public void readBytes(OutputStream out,
                      int length)
               throws IOException

Throws:

IOException

skipBytes

public int skipBytes(int length)

Specified by:

skipBytes in interface DataInput

Specified by:

skipBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeByte

public void writeByte(byte value)

Specified by:

writeByte in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeShort

public void writeShort(short value)

Specified by:

writeShort in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeMedium

public void writeMedium(int value)

writeInt

public void writeInt(int value)

Specified by:

writeInt in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeLong

public void writeLong(long value)

Specified by:

writeLong in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeBytes

public void writeBytes(byte[] src,
                       int srcIndex,
                       int length)

Specified by:

writeBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeBytes

public void writeBytes(byte[] src)

Specified by:

writeBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeBytes

public void writeBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer src)

writeBytes

public void writeBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer src,
                       int length)

Specified by:

writeBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeBytes

public void writeBytes(ByteBuffer src)

Specified by:

writeBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeBytes

public int writeBytes(InputStream in,
                      int length)
               throws IOException

Throws:

IOException

writeBytes

public int writeBytes(ScatteringByteChannel in,
                      int length)
               throws IOException

Throws:

IOException

writeZero

public void writeZero(int length)

toByteBuffer

public ByteBuffer toByteBuffer()

Specified by:

toByteBuffer in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

toByteBuffers

public ByteBuffer[] toByteBuffers()

toByteBuffers

public ByteBuffer[] toByteBuffers(int index,
                                  int length)

toString

public String toString(String charsetName)

getUnderlyingBuffer

public Object getUnderlyingBuffer()

readBoolean

public boolean readBoolean()

Specified by:

readBoolean in interface DataInput

Specified by:

readBoolean in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readChar

public char readChar()

Specified by:

readChar in interface DataInput

Specified by:

readChar in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getChar

public char getChar(int index)

Specified by:

getChar in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getDouble

public double getDouble(int index)

Specified by:

getDouble in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

getFloat

public float getFloat(int index)

Specified by:

getFloat in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readBytes

public org.apache.activemq.artemis.api.core.ActiveMQBuffer readBytes(int length)

Specified by:

readBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readDouble

public double readDouble()

Specified by:

readDouble in interface DataInput

Specified by:

readDouble in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readFloat

public float readFloat()

Specified by:

readFloat in interface DataInput

Specified by:

readFloat in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readNullableSimpleString

public org.apache.activemq.artemis.api.core.SimpleString readNullableSimpleString()

Specified by:

readNullableSimpleString in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readNullableString

public String readNullableString()

Specified by:

readNullableString in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readSimpleString

public org.apache.activemq.artemis.api.core.SimpleString readSimpleString()

Specified by:

readSimpleString in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readString

public String readString()

Specified by:

readString in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readUTF

public String readUTF()

Specified by:

readUTF in interface DataInput

Specified by:

readUTF in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeBoolean

public void writeBoolean(boolean val)

Specified by:

writeBoolean in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeChar

public void writeChar(char val)

Specified by:

writeChar in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeDouble

public void writeDouble(double val)

Specified by:

writeDouble in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeFloat

public void writeFloat(float val)

Specified by:

writeFloat in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeNullableSimpleString

public void writeNullableSimpleString(org.apache.activemq.artemis.api.core.SimpleString val)

Specified by:

writeNullableSimpleString in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeNullableString

public void writeNullableString(String val)

Specified by:

writeNullableString in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeSimpleString

public void writeSimpleString(org.apache.activemq.artemis.api.core.SimpleString val)

Specified by:

writeSimpleString in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeString

public void writeString(String val)

Specified by:

writeString in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeUTF

public void writeUTF(String utf)

Specified by:

writeUTF in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

copy

public org.apache.activemq.artemis.api.core.ActiveMQBuffer copy()

Specified by:

copy in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

slice

public org.apache.activemq.artemis.api.core.ActiveMQBuffer slice(int index,
                                                                 int length)

Specified by:

slice in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readFully

public void readFully(byte[] b)
               throws IOException

from DataInput interface

Specified by:

readFully in interface DataInput

Throws:

IOException

readFully

public void readFully(byte[] b,
                      int off,
                      int len)
               throws IOException

from DataInput interface

Specified by:

readFully in interface DataInput

Throws:

IOException

readLine

public String readLine()
                throws IOException

from DataInput interface

Specified by:

readLine in interface DataInput

Throws:

IOException

byteBuf

public io.netty.buffer.ByteBuf byteBuf()

Specified by:

byteBuf in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

copy

public org.apache.activemq.artemis.api.core.ActiveMQBuffer copy(int index,
                                                                int length)

Specified by:

copy in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

duplicate

public org.apache.activemq.artemis.api.core.ActiveMQBuffer duplicate()

Specified by:

duplicate in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

readSlice

public org.apache.activemq.artemis.api.core.ActiveMQBuffer readSlice(int length)

Specified by:

readSlice in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setChar

public void setChar(int index,
                    char value)

Specified by:

setChar in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setDouble

public void setDouble(int index,
                      double value)

Specified by:

setDouble in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

setFloat

public void setFloat(int index,
                     float value)

Specified by:

setFloat in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

slice

public org.apache.activemq.artemis.api.core.ActiveMQBuffer slice()

Specified by:

slice in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer

writeBytes

public void writeBytes(org.apache.activemq.artemis.api.core.ActiveMQBuffer src,
                       int srcIndex,
                       int length)

Specified by:

writeBytes in interface org.apache.activemq.artemis.api.core.ActiveMQBuffer