org.apache.activemq.artemis.core.buffers.impl

Class ResetLimitWrappedActiveMQBuffer

java.lang.Object

org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

org.apache.activemq.artemis.core.buffers.impl.ResetLimitWrappedActiveMQBuffer

All Implemented Interfaces:

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

public final class ResetLimitWrappedActiveMQBuffer
extends org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

A ResetLimitWrappedActiveMQBuffer TODO: Move this to commons

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

buffer

Constructor Summary

Constructors

Constructor and Description
ResetLimitWrappedActiveMQBuffer(int limit, org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, MessageInternal message)
ResetLimitWrappedActiveMQBuffer(int limit, io.netty.buffer.ByteBuf buffer, MessageInternal message)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	readerIndex(int readerIndex)
void	resetReaderIndex()
void	resetWriterIndex()
void	setBuffer(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)
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	setLong(int index, long value)
void	setMessage(MessageInternal message) We need to turn of notifications of body changes on reset on the server side when dealing with AMQP conversions, for that reason this method will set the message to null here
void	setShort(int index, short value)
void	writeBoolean(boolean val)
void	writeByte(byte value)
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)
void	writeChar(char chr)
void	writeDouble(double value)
void	writeFloat(float value)
void	writeInt(int value)
void	writeLong(long value)
void	writeNullableSimpleString(org.apache.activemq.artemis.api.core.SimpleString val)
void	writeNullableString(String val)
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)

Methods inherited from class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

byteBuf, capacity, copy, copy, discardReadBytes, duplicate, getByte, getBytes, getBytes, getBytes, getBytes, getBytes, getBytes, getChar, getDouble, getFloat, getInt, getLong, getShort, getUnsignedByte, getUnsignedInt, getUnsignedShort, markReaderIndex, markWriterIndex, readable, readableBytes, readBoolean, readByte, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readChar, readDouble, readerIndex, readFloat, readFully, readFully, readInt, readLine, readLong, readNullableSimpleString, readNullableString, readShort, readSimpleString, readSlice, readString, readUnsignedByte, readUnsignedInt, readUnsignedShort, readUTF, skipBytes, slice, slice, toByteBuffer, toByteBuffer, unwrap, writable, writableBytes, writerIndex

Methods inherited from class java.lang.Object

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

Constructor Detail

ResetLimitWrappedActiveMQBuffer

public ResetLimitWrappedActiveMQBuffer(int limit,
                                       org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer,
                                       MessageInternal message)

ResetLimitWrappedActiveMQBuffer

public ResetLimitWrappedActiveMQBuffer(int limit,
                                       io.netty.buffer.ByteBuf buffer,
                                       MessageInternal message)

Method Detail

setMessage

public void setMessage(MessageInternal message)

We need to turn of notifications of body changes on reset on the server side when dealing with AMQP conversions, for that reason this method will set the message to null here

Parameters:

message -

setBuffer

public void setBuffer(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer)

clear

public void clear()

Specified by:

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

Overrides:

clear in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

readerIndex

public void readerIndex(int readerIndex)

Specified by:

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

Overrides:

readerIndex in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

resetReaderIndex

public void resetReaderIndex()

Specified by:

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

Overrides:

resetReaderIndex in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

resetWriterIndex

public void resetWriterIndex()

Specified by:

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

Overrides:

resetWriterIndex in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setIndex

public void setIndex(int readerIndex,
                     int writerIndex)

Specified by:

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

Overrides:

setIndex in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writerIndex

public void writerIndex(int writerIndex)

Specified by:

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

Overrides:

writerIndex in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setByte

public void setByte(int index,
                    byte value)

Specified by:

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

Overrides:

setByte in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setBytes

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

Specified by:

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

Overrides:

setBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setBytes

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

Specified by:

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

Overrides:

setBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setBytes

public void setBytes(int index,
                     ByteBuffer src)

Specified by:

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

Overrides:

setBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

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

Overrides:

setBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

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

Overrides:

setBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

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

Overrides:

setBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setChar

public void setChar(int index,
                    char value)

Specified by:

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

Overrides:

setChar in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setDouble

public void setDouble(int index,
                      double value)

Specified by:

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

Overrides:

setDouble in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setFloat

public void setFloat(int index,
                     float value)

Specified by:

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

Overrides:

setFloat in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setInt

public void setInt(int index,
                   int value)

Specified by:

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

Overrides:

setInt in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setLong

public void setLong(int index,
                    long value)

Specified by:

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

Overrides:

setLong in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

setShort

public void setShort(int index,
                     short value)

Specified by:

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

Overrides:

setShort in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeBoolean

public void writeBoolean(boolean val)

Specified by:

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

Overrides:

writeBoolean in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeByte

public void writeByte(byte value)

Specified by:

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

Overrides:

writeByte in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeBytes

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

Specified by:

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

Overrides:

writeBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeBytes

public void writeBytes(byte[] src)

Specified by:

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

Overrides:

writeBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeBytes

public void writeBytes(ByteBuffer src)

Specified by:

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

Overrides:

writeBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

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

Overrides:

writeBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

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

Overrides:

writeBytes in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeChar

public void writeChar(char chr)

Specified by:

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

Overrides:

writeChar in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeDouble

public void writeDouble(double value)

Specified by:

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

Overrides:

writeDouble in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeFloat

public void writeFloat(float value)

Specified by:

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

Overrides:

writeFloat in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeInt

public void writeInt(int value)

Specified by:

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

Overrides:

writeInt in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeLong

public void writeLong(long value)

Specified by:

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

Overrides:

writeLong in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeNullableSimpleString

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

Specified by:

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

Overrides:

writeNullableSimpleString in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeNullableString

public void writeNullableString(String val)

Specified by:

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

Overrides:

writeNullableString in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeShort

public void writeShort(short value)

Specified by:

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

Overrides:

writeShort in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeSimpleString

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

Specified by:

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

Overrides:

writeSimpleString in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeString

public void writeString(String val)

Specified by:

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

Overrides:

writeString in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper

writeUTF

public void writeUTF(String utf)

Specified by:

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

Overrides:

writeUTF in class org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper