Package org.apache.qpid.protonj2.buffer

Class ProtonDuplicatedBuffer

java.lang.Object

org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer

org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer

All Implemented Interfaces:

Comparable<ProtonBuffer>, ProtonBuffer

public class ProtonDuplicatedBuffer
extends ProtonAbstractBuffer

A duplicated buffer wrapper for buffers known to be ProtonAbstractBuffer instances.

Field Summary

Fields inherited from class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer

markedReadIndex, markedWriteIndex, readIndex, writeIndex

Constructor Summary

Constructors

Constructor	Description
ProtonDuplicatedBuffer(ProtonAbstractBuffer buffer)	Wrap the given buffer to present a duplicate buffer with independent read and write index values.

Method Summary

Modifier and Type	Method	Description
int	capacity()
ProtonBuffer	capacity(int newCapacity)	Adjusts the capacity of this buffer.
ProtonBuffer	copy(int index, int length)	Returns a copy of this buffer's sub-region.
ProtonBuffer	duplicate()	Create a duplicate of this ProtonBuffer instance that shares the same backing data store and but maintains separate position index values.
byte[]	getArray()	Returns the backing array for this ProtonBuffer instance if there is such an array or throws an exception if this ProtonBuffer implementation has no backing array.
int	getArrayOffset()
byte	getByte(int index)	Gets a byte from the specified index, this method will not modify the read or write index.
ProtonBuffer	getBytes(int index, byte[] destination, int offset, int length)	Transfers this buffer's data to the specified destination starting at the specified absolute index.
ProtonBuffer	getBytes(int index, ByteBuffer destination)	Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination's position reaches its limit.
ProtonBuffer	getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)	Transfers this buffer's data to the specified destination starting at the specified absolute index.
int	getInt(int index)	Gets a int from the specified index, this method will not modify the read or write index.
long	getLong(int index)	Gets a long from the specified index, this method will not modify the read or write index.
short	getShort(int index)	Gets a short from the specified index, this method will not modify the read or write index.
boolean	hasArray()
ProtonBuffer	setByte(int index, int value)	Sets the byte value at the given write index in this buffer's backing data store.
ProtonBuffer	setBytes(int index, byte[] source, int sourceIndex, int length)	Transfers the specified source array's data to this buffer starting at the specified absolute index.
ProtonBuffer	setBytes(int index, ByteBuffer source)	Transfers the specified source buffer's data to this buffer starting at the specified absolute index until the source buffer's position reaches its limit.
ProtonBuffer	setBytes(int index, ProtonBuffer source, int sourceIndex, int length)	Transfers the specified source buffer's data to this buffer starting at the specified absolute index.
ProtonBuffer	setInt(int index, int value)	Sets the int value at the given write index in this buffer's backing data store.
ProtonBuffer	setLong(int index, long value)	Sets the long value at the given write index in this buffer's backing data store.
ProtonBuffer	setShort(int index, int value)	Sets the short value at the given write index in this buffer's backing data store.
ProtonBuffer	slice(int index, int length)	Create a new ProtonBuffer whose contents are a subsequence of the contents of this ProtonBuffer.
ByteBuffer	toByteBuffer(int index, int length)	Returns a ByteBuffer that represents the given span of bytes from the readable portion of this buffer.

Methods inherited from class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer

adjustIndexMarks, checkDestinationIndex, checkIndex, checkNewCapacity, checkReadableBytes, checkSourceIndex, clear, compareTo, copy, ensureWritable, equals, getBoolean, getBytes, getBytes, getBytes, getChar, getDouble, getFloat, getMaxWritableBytes, getReadableBytes, getReadIndex, getUnsignedByte, getUnsignedInt, getUnsignedShort, getWritableBytes, getWriteIndex, hashCode, isOutOfBounds, isReadable, isReadable, isWritable, isWritable, markReadIndex, markWriteIndex, maxCapacity, readBoolean, readByte, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readBytes, readDouble, readFloat, readInt, readLong, readShort, resetReadIndex, resetWriteIndex, setBoolean, setBytes, setBytes, setBytes, setChar, setDouble, setFloat, setIndex, setReadIndex, setWriteIndex, skipBytes, slice, toByteBuffer, toString, toString, writeBoolean, writeByte, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeDouble, writeFloat, writeInt, writeLong, writeShort

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.protonj2.buffer.ProtonBuffer

unwrap

Constructor Detail

ProtonDuplicatedBuffer

public ProtonDuplicatedBuffer(ProtonAbstractBuffer buffer)

Wrap the given buffer to present a duplicate buffer with independent read and write index values.

Parameters:

buffer - The ProtonAbstractBuffer instance to wrap with this instance.

Method Detail

hasArray

public boolean hasArray()

Returns:

true if this buffer has a backing byte array that can be accessed.

getArray

public byte[] getArray()

Description copied from interface: ProtonBuffer

Returns the backing array for this ProtonBuffer instance if there is such an array or throws an exception if this ProtonBuffer implementation has no backing array.

Changes to the returned array are visible to other users of this ProtonBuffer.

Returns:

the backing byte array for this ProtonBuffer.

getArrayOffset

public int getArrayOffset()

Returns:

the offset of the first byte in the backing array belonging to this buffer.

capacity

public int capacity()

Returns:

the number of bytes this buffer can currently contain.

capacity

public ProtonBuffer capacity(int newCapacity)

Description copied from interface: ProtonBuffer

Adjusts the capacity of this buffer. If the new capacity is less than the current capacity, the content of this buffer is truncated. If the new capacity is greater than the current capacity, the buffer is appended with unspecified data whose length is new capacity - current capacity.

Parameters:

newCapacity - the new maximum capacity value of this buffer.

Returns:

this buffer for using in call chaining.

duplicate

public ProtonBuffer duplicate()

Description copied from interface: ProtonBuffer

Create a duplicate of this ProtonBuffer instance that shares the same backing data store and but maintains separate position index values. Changes to one buffer are visible in any of its duplicates. This method does not copy the read or write markers to the new buffer instance.

Specified by:

duplicate in interface ProtonBuffer

Overrides:

duplicate in class ProtonAbstractBuffer

Returns:

a new ProtonBuffer instance that shares the backing data as this one.

slice

public ProtonBuffer slice(int index,
                          int length)

Description copied from interface: ProtonBuffer

Create a new ProtonBuffer whose contents are a subsequence of the contents of this ProtonBuffer.

The starting point of the new buffer starts at given index into this buffer and spans the number of bytes given by the length. Changes to the contents of this buffer or to the produced slice buffer are visible in the other.

Specified by:

slice in interface ProtonBuffer

Overrides:

slice in class ProtonAbstractBuffer

Parameters:

index - The index in this buffer where the slice should begin.

length - The number of bytes to make visible to the new buffer from this one.

Returns:

a new ProtonBuffer whose contents are a subsequence of this buffer.

getByte

public byte getByte(int index)

Description copied from interface: ProtonBuffer

Gets a byte from the specified index, this method will not modify the read or write index.

Parameters:

index - The index into the buffer where the value should be read.

Returns:

the value read from the given index.

getShort

public short getShort(int index)

Description copied from interface: ProtonBuffer

Gets a short from the specified index, this method will not modify the read or write index.

Parameters:

index - The index into the buffer where the value should be read.

Returns:

the value read from the given index.

getInt

public int getInt(int index)

Description copied from interface: ProtonBuffer

Gets a int from the specified index, this method will not modify the read or write index.

Parameters:

index - The index into the buffer where the value should be read.

Returns:

the value read from the given index.

getLong

public long getLong(int index)

Description copied from interface: ProtonBuffer

Gets a long from the specified index, this method will not modify the read or write index.

Parameters:

index - The index into the buffer where the value should be read.

Returns:

the value read from the given index.

getBytes

public ProtonBuffer getBytes(int index,
                             ProtonBuffer destination,
                             int destinationIndex,
                             int length)

Description copied from interface: ProtonBuffer

Transfers this buffer's data to the specified destination starting at the specified absolute index. This method does not modify readIndex or writeIndex of both the source (i.e. this) and the destination.

Parameters:

index - The index into the buffer where the value should be read.

destination - The buffer where the bytes read will be written to

destinationIndex - The offset into the destination where the write starts

length - The number of bytes to transfer

Returns:

this buffer for chaining

getBytes

public ProtonBuffer getBytes(int index,
                             byte[] destination,
                             int offset,
                             int length)

Description copied from interface: ProtonBuffer

Transfers this buffer's data to the specified destination starting at the specified absolute index. This method does not modify #getReadIndex() or #getWriteIndex() of this buffer.

Parameters:

index - The index into the buffer where the value should be read.

destination - The buffer where the bytes read will be written to

offset - the offset into the destination to begin writing the bytes.

length - the number of bytes to transfer from this buffer to the target buffer.

Returns:

this buffer for chaining

getBytes

public ProtonBuffer getBytes(int index,
                             ByteBuffer destination)

Description copied from interface: ProtonBuffer

Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination's position reaches its limit. This method does not modify #getReadIndex() or #getWriteIndex() of this buffer while the destination's position will be increased.

Parameters:

index - The index into the buffer where the value should be read.

destination - The buffer where the bytes read will be written to

Returns:

this buffer for chaining

setByte

public ProtonBuffer setByte(int index,
                            int value)

Description copied from interface: ProtonBuffer

Sets the byte value at the given write index in this buffer's backing data store.

Parameters:

index - The index to start the write from.

value - The value to write at the given index.

Returns:

a reference to this ProtonBuffer for chaining.

setShort

public ProtonBuffer setShort(int index,
                             int value)

Description copied from interface: ProtonBuffer

Sets the short value at the given write index in this buffer's backing data store.

Parameters:

index - The index to start the write from.

value - The value to write at the given index.

Returns:

a reference to this ProtonBuffer for chaining.

setInt

public ProtonBuffer setInt(int index,
                           int value)

Description copied from interface: ProtonBuffer

Sets the int value at the given write index in this buffer's backing data store.

Parameters:

index - The index to start the write from.

value - The value to write at the given index.

Returns:

a reference to this ProtonBuffer for chaining.

setLong

public ProtonBuffer setLong(int index,
                            long value)

Description copied from interface: ProtonBuffer

Sets the long value at the given write index in this buffer's backing data store.

Parameters:

index - The index to start the write from.

value - The value to write at the given index.

Returns:

a reference to this ProtonBuffer for chaining.

setBytes

public ProtonBuffer setBytes(int index,
                             ProtonBuffer source,
                             int sourceIndex,
                             int length)

Description copied from interface: ProtonBuffer

Transfers the specified source buffer's data to this buffer starting at the specified absolute index. This method does not modify readIndex or writeIndex of both the source (i.e. this) and the destination.

Parameters:

index - The index in this buffer where the write operation starts.

source - The source buffer from which the bytes are read.

sourceIndex - The offset into the source where the set begins.

length - The number of bytes to transfer

Returns:

this buffer for chaining

setBytes

public ProtonBuffer setBytes(int index,
                             byte[] source,
                             int sourceIndex,
                             int length)

Description copied from interface: ProtonBuffer

Transfers the specified source array's data to this buffer starting at the specified absolute index. This method does not modify readIndex or writeIndex of this buffer.

Parameters:

index - The index in this buffer where the write operation starts.

source - The source buffer from which the bytes are read.

sourceIndex - The offset into the source where the set begins.

length - The number of bytes to transfer

Returns:

this buffer for chaining

setBytes

public ProtonBuffer setBytes(int index,
                             ByteBuffer source)

Description copied from interface: ProtonBuffer

Transfers the specified source buffer's data to this buffer starting at the specified absolute index until the source buffer's position reaches its limit. This method does not modify readIndex or writeIndex of this buffer.

Parameters:

index - The index in this buffer where the write operation starts.

source - The source buffer from which the bytes are read.

Returns:

this buffer for chaining

copy

public ProtonBuffer copy(int index,
                         int length)

Description copied from interface: ProtonBuffer

Returns a copy of this buffer's sub-region. Modifying the content of the returned buffer or this buffer does not affect each other at all. This method does not modify the value returned from ProtonBuffer.getReadIndex() or ProtonBuffer.getWriteIndex() of this buffer.

Specified by:

copy in interface ProtonBuffer

Specified by:

copy in class ProtonAbstractBuffer

Parameters:

index - The index in this buffer where the copy should begin

length - The number of bytes to copy to the new buffer from this one.

Returns:

a new ProtonBuffer instance containing the copied bytes.

toByteBuffer

public ByteBuffer toByteBuffer(int index,
                               int length)

Description copied from interface: ProtonBuffer

Returns a ByteBuffer that represents the given span of bytes from the readable portion of this buffer.

This method should attempt to return a ByteBuffer that shares the backing data store with this buffer however if that is not possible it is permitted that the returned ByteBuffer contain a copy of the readable bytes of this ProtonBuffer.

Specified by:

toByteBuffer in interface ProtonBuffer

Specified by:

toByteBuffer in class ProtonAbstractBuffer

Parameters:

index - The starting index in this where the ByteBuffer view should begin.

length - The number of bytes to include in the ByteBuffer view.

Returns:

a ByteBuffer that represents the given view of this buffers readable bytes.