public final class ResetLimitWrappedActiveMQBuffer extends ChannelBufferWrapper
buffer
Constructor and Description |
---|
ResetLimitWrappedActiveMQBuffer(int limit,
ActiveMQBuffer buffer,
MessageInternal message) |
ResetLimitWrappedActiveMQBuffer(int limit,
io.netty.buffer.ByteBuf buffer,
MessageInternal message) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
readerIndex(int readerIndex) |
void |
resetReaderIndex() |
void |
resetWriterIndex() |
void |
setBuffer(ActiveMQBuffer buffer) |
void |
setByte(int index,
byte value) |
void |
setBytes(int index,
ActiveMQBuffer src) |
void |
setBytes(int index,
ActiveMQBuffer src,
int length) |
void |
setBytes(int index,
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(ActiveMQBuffer src,
int length) |
void |
writeBytes(ActiveMQBuffer src,
int srcIndex,
int length) |
void |
writeBytes(byte[] src) |
void |
writeBytes(byte[] src,
int srcIndex,
int length) |
void |
writeBytes(ByteBuffer src) |
void |
writeBytes(io.netty.buffer.ByteBuf src,
int srcIndex,
int length) |
void |
writeChar(char chr) |
void |
writeDouble(double value) |
void |
writeFloat(float value) |
void |
writeInt(int value) |
void |
writeLong(long value) |
void |
writeNullableSimpleString(SimpleString val) |
void |
writeNullableString(String val) |
void |
writerIndex(int writerIndex) |
void |
writeShort(short value) |
void |
writeSimpleString(SimpleString val) |
void |
writeString(String val) |
void |
writeUTF(String utf) |
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, release, skipBytes, slice, slice, toByteBuffer, toByteBuffer, unwrap, writable, writableBytes, writerIndex
public ResetLimitWrappedActiveMQBuffer(int limit, ActiveMQBuffer buffer, MessageInternal message)
public ResetLimitWrappedActiveMQBuffer(int limit, io.netty.buffer.ByteBuf buffer, MessageInternal message)
public void setMessage(MessageInternal message)
message
- public void setBuffer(ActiveMQBuffer buffer)
public void clear()
clear
in interface ActiveMQBuffer
clear
in class ChannelBufferWrapper
public void readerIndex(int readerIndex)
readerIndex
in interface ActiveMQBuffer
readerIndex
in class ChannelBufferWrapper
public void resetReaderIndex()
resetReaderIndex
in interface ActiveMQBuffer
resetReaderIndex
in class ChannelBufferWrapper
public void resetWriterIndex()
resetWriterIndex
in interface ActiveMQBuffer
resetWriterIndex
in class ChannelBufferWrapper
public void setIndex(int readerIndex, int writerIndex)
setIndex
in interface ActiveMQBuffer
setIndex
in class ChannelBufferWrapper
public void writerIndex(int writerIndex)
writerIndex
in interface ActiveMQBuffer
writerIndex
in class ChannelBufferWrapper
public void setByte(int index, byte value)
setByte
in interface ActiveMQBuffer
setByte
in class ChannelBufferWrapper
public void setBytes(int index, byte[] src, int srcIndex, int length)
setBytes
in interface ActiveMQBuffer
setBytes
in class ChannelBufferWrapper
public void setBytes(int index, byte[] src)
setBytes
in interface ActiveMQBuffer
setBytes
in class ChannelBufferWrapper
public void setBytes(int index, ByteBuffer src)
setBytes
in interface ActiveMQBuffer
setBytes
in class ChannelBufferWrapper
public void setBytes(int index, ActiveMQBuffer src, int srcIndex, int length)
setBytes
in interface ActiveMQBuffer
setBytes
in class ChannelBufferWrapper
public void setBytes(int index, ActiveMQBuffer src, int length)
setBytes
in interface ActiveMQBuffer
setBytes
in class ChannelBufferWrapper
public void setBytes(int index, ActiveMQBuffer src)
setBytes
in interface ActiveMQBuffer
setBytes
in class ChannelBufferWrapper
public void setChar(int index, char value)
setChar
in interface ActiveMQBuffer
setChar
in class ChannelBufferWrapper
public void setDouble(int index, double value)
setDouble
in interface ActiveMQBuffer
setDouble
in class ChannelBufferWrapper
public void setFloat(int index, float value)
setFloat
in interface ActiveMQBuffer
setFloat
in class ChannelBufferWrapper
public void setInt(int index, int value)
setInt
in interface ActiveMQBuffer
setInt
in class ChannelBufferWrapper
public void setLong(int index, long value)
setLong
in interface ActiveMQBuffer
setLong
in class ChannelBufferWrapper
public void setShort(int index, short value)
setShort
in interface ActiveMQBuffer
setShort
in class ChannelBufferWrapper
public void writeBoolean(boolean val)
writeBoolean
in interface ActiveMQBuffer
writeBoolean
in class ChannelBufferWrapper
public void writeByte(byte value)
writeByte
in interface ActiveMQBuffer
writeByte
in class ChannelBufferWrapper
public void writeBytes(byte[] src, int srcIndex, int length)
writeBytes
in interface ActiveMQBuffer
writeBytes
in class ChannelBufferWrapper
public void writeBytes(byte[] src)
writeBytes
in interface ActiveMQBuffer
writeBytes
in class ChannelBufferWrapper
public void writeBytes(ByteBuffer src)
writeBytes
in interface ActiveMQBuffer
writeBytes
in class ChannelBufferWrapper
public void writeBytes(io.netty.buffer.ByteBuf src, int srcIndex, int length)
writeBytes
in interface ActiveMQBuffer
writeBytes
in class ChannelBufferWrapper
public void writeBytes(ActiveMQBuffer src, int srcIndex, int length)
writeBytes
in interface ActiveMQBuffer
writeBytes
in class ChannelBufferWrapper
public void writeBytes(ActiveMQBuffer src, int length)
writeBytes
in interface ActiveMQBuffer
writeBytes
in class ChannelBufferWrapper
public void writeChar(char chr)
writeChar
in interface ActiveMQBuffer
writeChar
in class ChannelBufferWrapper
public void writeDouble(double value)
writeDouble
in interface ActiveMQBuffer
writeDouble
in class ChannelBufferWrapper
public void writeFloat(float value)
writeFloat
in interface ActiveMQBuffer
writeFloat
in class ChannelBufferWrapper
public void writeInt(int value)
writeInt
in interface ActiveMQBuffer
writeInt
in class ChannelBufferWrapper
public void writeLong(long value)
writeLong
in interface ActiveMQBuffer
writeLong
in class ChannelBufferWrapper
public void writeNullableSimpleString(SimpleString val)
writeNullableSimpleString
in interface ActiveMQBuffer
writeNullableSimpleString
in class ChannelBufferWrapper
public void writeNullableString(String val)
writeNullableString
in interface ActiveMQBuffer
writeNullableString
in class ChannelBufferWrapper
public void writeShort(short value)
writeShort
in interface ActiveMQBuffer
writeShort
in class ChannelBufferWrapper
public void writeSimpleString(SimpleString val)
writeSimpleString
in interface ActiveMQBuffer
writeSimpleString
in class ChannelBufferWrapper
public void writeString(String val)
writeString
in interface ActiveMQBuffer
writeString
in class ChannelBufferWrapper
public void writeUTF(String utf)
writeUTF
in interface ActiveMQBuffer
writeUTF
in class ChannelBufferWrapper
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.