Uses of Interface
org.apache.qpid.protonj2.buffer.ProtonBuffer
-
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.buffer
Classes in org.apache.qpid.protonj2.buffer that implement ProtonBuffer Modifier and Type Class Description class
ProtonAbstractBuffer
Base class used to hold the common implementation details for Proton buffer implementations.class
ProtonByteBuffer
Implementation of the ProtonBuffer interface that uses an array backing the buffer that is dynamically resized as bytes are written.class
ProtonCompositeBuffer
A composite of 1 or more ProtonBuffer instances used when aggregating buffer views.class
ProtonDuplicatedBuffer
A duplicated buffer wrapper for buffers known to beProtonAbstractBuffer
instances.class
ProtonNettyByteBuffer
Wrapper class for Netty ByteBuf instancesclass
ProtonNioByteBuffer
ProtonBuffer wrapper around a NIO ByteBuffer instance.class
ProtonSlicedBuffer
Presents a sliced view of aProtonAbstractBuffer
.Methods in org.apache.qpid.protonj2.buffer that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
ProtonBufferAllocator. allocate()
Create a new ProtonBuffer instance with default initial capacity.ProtonBuffer
ProtonBufferAllocator. allocate(int initialCapacity)
Create a new ProtonBuffer instance with the given initial capacity and the maximum capacity should be that of the underlying buffer implementations limit.ProtonBuffer
ProtonBufferAllocator. allocate(int initialCapacity, int maximumCapacity)
Create a new ProtonBuffer instance with the given initial capacity and the maximum capacity should that of the value specified by the caller.ProtonBuffer
ProtonBuffer. capacity(int newCapacity)
Adjusts the capacity of this buffer.ProtonBuffer
ProtonByteBuffer. capacity(int newCapacity)
ProtonBuffer
ProtonCompositeBuffer. capacity(int newCapacity)
ProtonBuffer
ProtonDuplicatedBuffer. capacity(int newCapacity)
ProtonBuffer
ProtonNettyByteBuffer. capacity(int newCapacity)
ProtonBuffer
ProtonNioByteBuffer. capacity(int newCapacity)
ProtonBuffer
ProtonSlicedBuffer. capacity(int newCapacity)
ProtonBuffer
ProtonAbstractBuffer. clear()
ProtonBuffer
ProtonBuffer. clear()
Reset the read and write offsets to zero and clears the position markers if set previously, this method is not required to reset the data previously written to this buffer.ProtonBuffer
ProtonNettyByteBuffer. clear()
ProtonBuffer
ProtonAbstractBuffer. copy()
abstract ProtonBuffer
ProtonAbstractBuffer. copy(int index, int length)
ProtonBuffer
ProtonBuffer. copy()
Create a deep copy of the readable bytes of this ProtonBuffer, the returned buffer can be modified without affecting the contents or position markers of this instance.ProtonBuffer
ProtonBuffer. copy(int index, int length)
Returns a copy of this buffer's sub-region.ProtonBuffer
ProtonByteBuffer. copy(int index, int length)
ProtonBuffer
ProtonCompositeBuffer. copy(int index, int length)
ProtonBuffer
ProtonDuplicatedBuffer. copy(int index, int length)
ProtonBuffer
ProtonNettyByteBuffer. copy()
ProtonBuffer
ProtonNettyByteBuffer. copy(int index, int length)
ProtonBuffer
ProtonNioByteBuffer. copy(int index, int length)
ProtonBuffer
ProtonSlicedBuffer. copy(int index, int length)
ProtonBuffer
ProtonAbstractBuffer. duplicate()
ProtonBuffer
ProtonBuffer. duplicate()
Create a duplicate of this ProtonBuffer instance that shares the same backing data store and but maintains separate position index values.ProtonBuffer
ProtonCompositeBuffer. duplicate()
ProtonBuffer
ProtonDuplicatedBuffer. duplicate()
ProtonBuffer
ProtonNettyByteBuffer. duplicate()
ProtonBuffer
ProtonSlicedBuffer. duplicate()
ProtonBuffer
ProtonAbstractBuffer. ensureWritable(int minWritableBytes)
ProtonBuffer
ProtonBuffer. ensureWritable(int amount)
Ensures that the requested number of bytes is available for write operations in the current buffer, growing the buffer if needed to meet the requested writable capacity.ProtonBuffer
ProtonNettyByteBuffer. ensureWritable(int minWritableBytes)
ProtonBuffer
ProtonAbstractBuffer. getBytes(int index, byte[] target)
ProtonBuffer
ProtonAbstractBuffer. getBytes(int index, ProtonBuffer target)
ProtonBuffer
ProtonAbstractBuffer. getBytes(int index, ProtonBuffer target, int length)
ProtonBuffer
ProtonBuffer. getBytes(int index, byte[] destination)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
.ProtonBuffer
ProtonBuffer. getBytes(int index, byte[] destination, int offset, int length)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
.ProtonBuffer
ProtonBuffer. getBytes(int index, java.nio.ByteBuffer destination)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
until the destination's position reaches its limit.ProtonBuffer
ProtonBuffer. getBytes(int index, ProtonBuffer destination)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
until the destination becomes non-writable.ProtonBuffer
ProtonBuffer. getBytes(int index, ProtonBuffer destination, int length)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
.ProtonBuffer
ProtonBuffer. getBytes(int index, ProtonBuffer destination, int offset, int length)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
.ProtonBuffer
ProtonByteBuffer. getBytes(int index, byte[] destination, int destinationIndex, int length)
ProtonBuffer
ProtonByteBuffer. getBytes(int index, java.nio.ByteBuffer destination)
ProtonBuffer
ProtonByteBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)
ProtonBuffer
ProtonCompositeBuffer. getBytes(int index, byte[] destination, int offset, int length)
ProtonBuffer
ProtonCompositeBuffer. getBytes(int index, java.nio.ByteBuffer destination)
ProtonBuffer
ProtonCompositeBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)
ProtonBuffer
ProtonDuplicatedBuffer. getBytes(int index, byte[] destination, int offset, int length)
ProtonBuffer
ProtonDuplicatedBuffer. getBytes(int index, java.nio.ByteBuffer destination)
ProtonBuffer
ProtonDuplicatedBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, byte[] destination)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, byte[] destination, int offset, int length)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, java.nio.ByteBuffer destination)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination, int length)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination, int offset, int length)
ProtonBuffer
ProtonNioByteBuffer. getBytes(int index, byte[] destination, int offset, int length)
ProtonBuffer
ProtonNioByteBuffer. getBytes(int index, java.nio.ByteBuffer destination)
ProtonBuffer
ProtonNioByteBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, byte[] dst)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, byte[] dst, int offset, int length)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, java.nio.ByteBuffer destination)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst, int length)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst, int dstIndex, int length)
ProtonBuffer
ProtonAbstractBuffer. markReadIndex()
ProtonBuffer
ProtonBuffer. markReadIndex()
Marks the current read index so that it can later be restored by a call toresetReadIndex()
, the initial mark value is 0.ProtonBuffer
ProtonNettyByteBuffer. markReadIndex()
ProtonBuffer
ProtonAbstractBuffer. markWriteIndex()
ProtonBuffer
ProtonBuffer. markWriteIndex()
Marks the current write index so that it can later be restored by a call toresetWriteIndex()
, the initial mark value is 0.ProtonBuffer
ProtonNettyByteBuffer. markWriteIndex()
ProtonBuffer
ProtonBufferAllocator. outputBuffer(int initialCapacity)
Create a new output ProtonBuffer instance with the given initial capacity and the maximum capacity should be that of the underlying buffer implementations limit.ProtonBuffer
ProtonBufferAllocator. outputBuffer(int initialCapacity, int maximumCapacity)
Create a new output ProtonBuffer instance with the given initial capacity and the maximum capacity should that of the value specified by the caller.ProtonBuffer
ProtonByteBufferAllocator. outputBuffer(int initialCapacity)
ProtonBuffer
ProtonByteBufferAllocator. outputBuffer(int initialCapacity, int maximumCapacity)
ProtonBuffer
ProtonNettyByteBufferAllocator. outputBuffer(int initialCapacity)
ProtonBuffer
ProtonNettyByteBufferAllocator. outputBuffer(int initialCapacity, int maximumCapacity)
ProtonBuffer
ProtonAbstractBuffer. readBytes(byte[] target)
ProtonBuffer
ProtonAbstractBuffer. readBytes(byte[] target, int length)
ProtonBuffer
ProtonAbstractBuffer. readBytes(byte[] target, int offset, int length)
ProtonBuffer
ProtonAbstractBuffer. readBytes(java.nio.ByteBuffer dst)
ProtonBuffer
ProtonAbstractBuffer. readBytes(ProtonBuffer target)
ProtonBuffer
ProtonAbstractBuffer. readBytes(ProtonBuffer target, int length)
ProtonBuffer
ProtonAbstractBuffer. readBytes(ProtonBuffer target, int offset, int length)
ProtonBuffer
ProtonBuffer. readBytes(byte[] target)
Reads bytes from this buffer and writes them into the destination byte array incrementing the read index by the value of the length of the destination array.ProtonBuffer
ProtonBuffer. readBytes(byte[] target, int length)
Reads bytes from this buffer and writes them into the destination byte array incrementing the read index by the length value passed.ProtonBuffer
ProtonBuffer. readBytes(byte[] target, int offset, int length)
Reads bytes from this buffer and writes them into the destination byte array incrementing the read index by the length value passed, the bytes are read into the given buffer starting from the given offset value.ProtonBuffer
ProtonBuffer. readBytes(java.nio.ByteBuffer destination)
Transfers this buffer's data to the specified destination starting at the currentreadIndex
until the destination's position reaches its limit, and increases thereadIndex
by the number of the transferred bytes.ProtonBuffer
ProtonBuffer. readBytes(ProtonBuffer target)
Reads bytes from this buffer and writes them into the destination ProtonBuffer incrementing the read index by the value of the number of bytes written to the target.ProtonBuffer
ProtonBuffer. readBytes(ProtonBuffer target, int length)
Reads bytes from this buffer and writes them into the destination ProtonBuffer incrementing the read index by the number of bytes written.ProtonBuffer
ProtonBuffer. readBytes(ProtonBuffer target, int offset, int length)
Transfers this buffer's data to the specified destination starting at the currentreadIndex
and increases thereadIndex
by the number of the transferred bytes (=length
).ProtonBuffer
ProtonNettyByteBuffer. readBytes(byte[] destination)
ProtonBuffer
ProtonNettyByteBuffer. readBytes(byte[] destination, int length)
ProtonBuffer
ProtonNettyByteBuffer. readBytes(byte[] destination, int offset, int length)
ProtonBuffer
ProtonNettyByteBuffer. readBytes(java.nio.ByteBuffer destination)
ProtonBuffer
ProtonNettyByteBuffer. readBytes(ProtonBuffer destination)
ProtonBuffer
ProtonNettyByteBuffer. readBytes(ProtonBuffer destination, int length)
ProtonBuffer
ProtonNettyByteBuffer. readBytes(ProtonBuffer destination, int offset, int length)
ProtonBuffer
ProtonAbstractBuffer. resetReadIndex()
ProtonBuffer
ProtonBuffer. resetReadIndex()
Resets the current read index to the previously marked value.ProtonBuffer
ProtonNettyByteBuffer. resetReadIndex()
ProtonBuffer
ProtonAbstractBuffer. resetWriteIndex()
ProtonBuffer
ProtonBuffer. resetWriteIndex()
Resets the current write index to the previously marked value.ProtonBuffer
ProtonNettyByteBuffer. resetWriteIndex()
ProtonBuffer
ProtonAbstractBuffer. setBoolean(int index, boolean value)
ProtonBuffer
ProtonBuffer. setBoolean(int index, boolean value)
Sets the boolean value at the given write index in this buffer's backing data store.ProtonBuffer
ProtonNettyByteBuffer. setBoolean(int index, boolean value)
ProtonBuffer
ProtonSlicedBuffer. setBoolean(int index, boolean value)
ProtonBuffer
ProtonBuffer. setByte(int index, int value)
Sets the byte value at the given write index in this buffer's backing data store.ProtonBuffer
ProtonByteBuffer. setByte(int index, int value)
ProtonBuffer
ProtonCompositeBuffer. setByte(int index, int value)
ProtonBuffer
ProtonDuplicatedBuffer. setByte(int index, int value)
ProtonBuffer
ProtonNettyByteBuffer. setByte(int index, int value)
ProtonBuffer
ProtonNioByteBuffer. setByte(int index, int value)
ProtonBuffer
ProtonSlicedBuffer. setByte(int index, int value)
ProtonBuffer
ProtonAbstractBuffer. setBytes(int index, byte[] src)
ProtonBuffer
ProtonAbstractBuffer. setBytes(int index, ProtonBuffer source)
ProtonBuffer
ProtonAbstractBuffer. setBytes(int index, ProtonBuffer source, int length)
ProtonBuffer
ProtonBuffer. setBytes(int index, byte[] source)
Transfers the specified source array's data to this buffer starting at the specified absoluteindex
.ProtonBuffer
ProtonBuffer. setBytes(int index, byte[] source, int offset, int length)
Transfers the specified source array's data to this buffer starting at the specified absoluteindex
.ProtonBuffer
ProtonBuffer. setBytes(int index, java.nio.ByteBuffer source)
Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex
until the source buffer's position reaches its limit.ProtonBuffer
ProtonBuffer. setBytes(int index, ProtonBuffer source)
Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex
until the source buffer becomes unreadable.ProtonBuffer
ProtonBuffer. setBytes(int index, ProtonBuffer source, int length)
Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex
.ProtonBuffer
ProtonBuffer. setBytes(int index, ProtonBuffer source, int offset, int length)
Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex
.ProtonBuffer
ProtonByteBuffer. setBytes(int index, byte[] source, int sourceIndex, int length)
ProtonBuffer
ProtonByteBuffer. setBytes(int index, java.nio.ByteBuffer src)
ProtonBuffer
ProtonByteBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonCompositeBuffer. setBytes(int index, byte[] source, int sourceIndex, int length)
ProtonBuffer
ProtonCompositeBuffer. setBytes(int index, java.nio.ByteBuffer source)
ProtonBuffer
ProtonCompositeBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonDuplicatedBuffer. setBytes(int index, byte[] source, int sourceIndex, int length)
ProtonBuffer
ProtonDuplicatedBuffer. setBytes(int index, java.nio.ByteBuffer source)
ProtonBuffer
ProtonDuplicatedBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, byte[] value)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, byte[] value, int offset, int length)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, java.nio.ByteBuffer value)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value, int length)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value, int offset, int length)
ProtonBuffer
ProtonNioByteBuffer. setBytes(int index, byte[] source, int sourceIndex, int length)
ProtonBuffer
ProtonNioByteBuffer. setBytes(int index, java.nio.ByteBuffer source)
ProtonBuffer
ProtonNioByteBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, byte[] source)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, byte[] src, int srcIndex, int length)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, java.nio.ByteBuffer source)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, ProtonBuffer source)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, ProtonBuffer source, int length)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonAbstractBuffer. setChar(int index, int value)
ProtonBuffer
ProtonBuffer. setChar(int index, int value)
Sets the char value at the given write index in this buffer's backing data store.ProtonBuffer
ProtonNettyByteBuffer. setChar(int index, int value)
ProtonBuffer
ProtonSlicedBuffer. setChar(int index, int value)
ProtonBuffer
ProtonAbstractBuffer. setDouble(int index, double value)
ProtonBuffer
ProtonBuffer. setDouble(int index, double value)
Sets the double value at the given write index in this buffer's backing data store.ProtonBuffer
ProtonNettyByteBuffer. setDouble(int index, double value)
ProtonBuffer
ProtonSlicedBuffer. setDouble(int index, double value)
ProtonBuffer
ProtonAbstractBuffer. setFloat(int index, float value)
ProtonBuffer
ProtonBuffer. setFloat(int index, float value)
Sets the float value at the given write index in this buffer's backing data store.ProtonBuffer
ProtonNettyByteBuffer. setFloat(int index, float value)
ProtonBuffer
ProtonSlicedBuffer. setFloat(int index, float value)
ProtonBuffer
ProtonAbstractBuffer. setIndex(int readIndex, int writeIndex)
ProtonBuffer
ProtonBuffer. setIndex(int readIndex, int writeIndex)
Used to set the read index and the write index in one call.ProtonBuffer
ProtonNettyByteBuffer. setIndex(int readIndex, int writeIndex)
ProtonBuffer
ProtonBuffer. setInt(int index, int value)
Sets the int value at the given write index in this buffer's backing data store.ProtonBuffer
ProtonByteBuffer. setInt(int index, int value)
ProtonBuffer
ProtonCompositeBuffer. setInt(int index, int value)
ProtonBuffer
ProtonDuplicatedBuffer. setInt(int index, int value)
ProtonBuffer
ProtonNettyByteBuffer. setInt(int index, int value)
ProtonBuffer
ProtonNioByteBuffer. setInt(int index, int value)
ProtonBuffer
ProtonSlicedBuffer. setInt(int index, int value)
ProtonBuffer
ProtonBuffer. setLong(int index, long value)
Sets the long value at the given write index in this buffer's backing data store.ProtonBuffer
ProtonByteBuffer. setLong(int index, long value)
ProtonBuffer
ProtonCompositeBuffer. setLong(int index, long value)
ProtonBuffer
ProtonDuplicatedBuffer. setLong(int index, long value)
ProtonBuffer
ProtonNettyByteBuffer. setLong(int index, long value)
ProtonBuffer
ProtonNioByteBuffer. setLong(int index, long value)
ProtonBuffer
ProtonSlicedBuffer. setLong(int index, long value)
ProtonBuffer
ProtonAbstractBuffer. setReadIndex(int value)
ProtonBuffer
ProtonBuffer. setReadIndex(int value)
Sets the read index for this buffer.ProtonBuffer
ProtonNettyByteBuffer. setReadIndex(int index)
ProtonBuffer
ProtonBuffer. setShort(int index, int value)
Sets the short value at the given write index in this buffer's backing data store.ProtonBuffer
ProtonByteBuffer. setShort(int index, int value)
ProtonBuffer
ProtonCompositeBuffer. setShort(int index, int value)
ProtonBuffer
ProtonDuplicatedBuffer. setShort(int index, int value)
ProtonBuffer
ProtonNettyByteBuffer. setShort(int index, int value)
ProtonBuffer
ProtonNioByteBuffer. setShort(int index, int value)
ProtonBuffer
ProtonSlicedBuffer. setShort(int index, int value)
ProtonBuffer
ProtonAbstractBuffer. setWriteIndex(int value)
ProtonBuffer
ProtonBuffer. setWriteIndex(int value)
Sets the write index for this buffer.ProtonBuffer
ProtonNettyByteBuffer. setWriteIndex(int index)
ProtonBuffer
ProtonAbstractBuffer. skipBytes(int length)
ProtonBuffer
ProtonBuffer. skipBytes(int length)
Increases the currentreadIndex
of this buffer by the specifiedlength
.ProtonBuffer
ProtonNettyByteBuffer. skipBytes(int skippedBytes)
ProtonBuffer
ProtonAbstractBuffer. slice()
ProtonBuffer
ProtonAbstractBuffer. slice(int index, int length)
ProtonBuffer
ProtonBuffer. slice()
Create a new ProtonBuffer whose contents are a subsequence of the contents of thisProtonBuffer
.ProtonBuffer
ProtonBuffer. slice(int index, int length)
Create a new ProtonBuffer whose contents are a subsequence of the contents of thisProtonBuffer
.ProtonBuffer
ProtonDuplicatedBuffer. slice(int index, int length)
ProtonBuffer
ProtonNettyByteBuffer. slice()
ProtonBuffer
ProtonNettyByteBuffer. slice(int index, int length)
ProtonBuffer
ProtonSlicedBuffer. slice(int index, int length)
ProtonBuffer
ProtonBufferAllocator. wrap(byte[] array)
Create a new ProtonBuffer that wraps the given byte array.ProtonBuffer
ProtonBufferAllocator. wrap(byte[] array, int offset, int length)
Create a new ProtonBuffer that wraps the given byte array using the provided offset and length values to confine the view of that array.ProtonBuffer
ProtonBufferAllocator. wrap(java.nio.ByteBuffer buffer)
Create a new ProtonBuffer that wraps the given ByteBuffer.ProtonBuffer
ProtonByteBufferAllocator. wrap(byte[] array)
ProtonBuffer
ProtonByteBufferAllocator. wrap(byte[] array, int offset, int length)
ProtonBuffer
ProtonByteBufferAllocator. wrap(java.nio.ByteBuffer buffer)
ProtonBuffer
ProtonNettyByteBufferAllocator. wrap(byte[] array)
ProtonBuffer
ProtonNettyByteBufferAllocator. wrap(byte[] array, int offset, int length)
ProtonBuffer
ProtonNettyByteBufferAllocator. wrap(java.nio.ByteBuffer buffer)
ProtonBuffer
ProtonAbstractBuffer. writeBoolean(boolean value)
ProtonBuffer
ProtonBuffer. writeBoolean(boolean value)
Writes a single boolean to the buffer and advances the write index by one.ProtonBuffer
ProtonNettyByteBuffer. writeBoolean(boolean value)
ProtonBuffer
ProtonAbstractBuffer. writeByte(int value)
ProtonBuffer
ProtonBuffer. writeByte(int value)
Writes a single byte to the buffer and advances the write index by one.ProtonBuffer
ProtonNettyByteBuffer. writeByte(int value)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(byte[] source)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(byte[] source, int length)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(byte[] source, int offset, int length)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(java.nio.ByteBuffer source)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(ProtonBuffer source)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(ProtonBuffer source, int length)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(ProtonBuffer source, int offset, int length)
ProtonBuffer
ProtonBuffer. writeBytes(byte[] value)
Writes the contents of the given byte array into the buffer and advances the write index by the length of the given array.ProtonBuffer
ProtonBuffer. writeBytes(byte[] value, int length)
Writes the contents of the given byte array into the buffer and advances the write index by the length value given.ProtonBuffer
ProtonBuffer. writeBytes(byte[] value, int offset, int length)
Writes the contents of the given byte array into the buffer and advances the write index by the length value given.ProtonBuffer
ProtonBuffer. writeBytes(java.nio.ByteBuffer source)
Transfers the specified source buffer's data to this buffer starting at the currentwriteIndex
until the source buffer's position reaches its limit, and increases thewriteIndex
by the number of the transferred bytes.ProtonBuffer
ProtonBuffer. writeBytes(ProtonBuffer source)
Transfers the specified source buffer's data to this buffer starting at the currentwriteIndex
until the source buffer becomes unreadable, and increases thewriteIndex
by the number of the transferred bytes.ProtonBuffer
ProtonBuffer. writeBytes(ProtonBuffer source, int length)
Transfers the specified source buffer's data to this buffer starting at the currentwriteIndex
and increases thewriteIndex
by the number of the transferred bytes (=length
).ProtonBuffer
ProtonBuffer. writeBytes(ProtonBuffer source, int offset, int length)
Transfers the specified source buffer's data to this buffer starting at the currentwriteIndex
and increases thewriteIndex
by the number of the transferred bytes (=length
).ProtonBuffer
ProtonNettyByteBuffer. writeBytes(byte[] value)
ProtonBuffer
ProtonNettyByteBuffer. writeBytes(byte[] value, int length)
ProtonBuffer
ProtonNettyByteBuffer. writeBytes(byte[] array, int offset, int length)
ProtonBuffer
ProtonNettyByteBuffer. writeBytes(java.nio.ByteBuffer value)
ProtonBuffer
ProtonNettyByteBuffer. writeBytes(ProtonBuffer value)
ProtonBuffer
ProtonNettyByteBuffer. writeBytes(ProtonBuffer value, int length)
ProtonBuffer
ProtonNettyByteBuffer. writeBytes(ProtonBuffer value, int offset, int length)
ProtonBuffer
ProtonAbstractBuffer. writeDouble(double value)
ProtonBuffer
ProtonBuffer. writeDouble(double value)
Writes a single double to the buffer and advances the write index by eight.ProtonBuffer
ProtonNettyByteBuffer. writeDouble(double value)
ProtonBuffer
ProtonAbstractBuffer. writeFloat(float value)
ProtonBuffer
ProtonBuffer. writeFloat(float value)
Writes a single float to the buffer and advances the write index by four.ProtonBuffer
ProtonNettyByteBuffer. writeFloat(float value)
ProtonBuffer
ProtonAbstractBuffer. writeInt(int value)
ProtonBuffer
ProtonBuffer. writeInt(int value)
Writes a single integer to the buffer and advances the write index by four.ProtonBuffer
ProtonNettyByteBuffer. writeInt(int value)
ProtonBuffer
ProtonAbstractBuffer. writeLong(long value)
ProtonBuffer
ProtonBuffer. writeLong(long value)
Writes a single long to the buffer and advances the write index by eight.ProtonBuffer
ProtonNettyByteBuffer. writeLong(long value)
ProtonBuffer
ProtonAbstractBuffer. writeShort(short value)
ProtonBuffer
ProtonBuffer. writeShort(short value)
Writes a single short to the buffer and advances the write index by two.ProtonBuffer
ProtonNettyByteBuffer. writeShort(short value)
Methods in org.apache.qpid.protonj2.buffer with parameters of type ProtonBuffer Modifier and Type Method Description ProtonCompositeBuffer
ProtonCompositeBuffer. append(ProtonBuffer buffer)
Appends the givenProtonBuffer
to the end of the buffer segments that comprise this compositeProtonBuffer
instance.int
ProtonAbstractBuffer. compareTo(ProtonBuffer other)
int
ProtonBuffer. compareTo(ProtonBuffer buffer)
Compares the remaining content of the current buffer with the remaining content of the given buffer, which must not be null.int
ProtonNettyByteBuffer. compareTo(ProtonBuffer other)
ProtonBuffer
ProtonAbstractBuffer. getBytes(int index, ProtonBuffer target)
ProtonBuffer
ProtonAbstractBuffer. getBytes(int index, ProtonBuffer target, int length)
ProtonBuffer
ProtonBuffer. getBytes(int index, ProtonBuffer destination)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
until the destination becomes non-writable.ProtonBuffer
ProtonBuffer. getBytes(int index, ProtonBuffer destination, int length)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
.ProtonBuffer
ProtonBuffer. getBytes(int index, ProtonBuffer destination, int offset, int length)
Transfers this buffer's data to the specified destination starting at the specified absoluteindex
.ProtonBuffer
ProtonByteBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)
ProtonBuffer
ProtonCompositeBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)
ProtonBuffer
ProtonDuplicatedBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination, int length)
ProtonBuffer
ProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination, int offset, int length)
ProtonBuffer
ProtonNioByteBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst, int length)
ProtonBuffer
ProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst, int dstIndex, int length)
ProtonBuffer
ProtonAbstractBuffer. readBytes(ProtonBuffer target)
ProtonBuffer
ProtonAbstractBuffer. readBytes(ProtonBuffer target, int length)
ProtonBuffer
ProtonAbstractBuffer. readBytes(ProtonBuffer target, int offset, int length)
ProtonBuffer
ProtonBuffer. readBytes(ProtonBuffer target)
Reads bytes from this buffer and writes them into the destination ProtonBuffer incrementing the read index by the value of the number of bytes written to the target.ProtonBuffer
ProtonBuffer. readBytes(ProtonBuffer target, int length)
Reads bytes from this buffer and writes them into the destination ProtonBuffer incrementing the read index by the number of bytes written.ProtonBuffer
ProtonBuffer. readBytes(ProtonBuffer target, int offset, int length)
Transfers this buffer's data to the specified destination starting at the currentreadIndex
and increases thereadIndex
by the number of the transferred bytes (=length
).ProtonBuffer
ProtonNettyByteBuffer. readBytes(ProtonBuffer destination)
ProtonBuffer
ProtonNettyByteBuffer. readBytes(ProtonBuffer destination, int length)
ProtonBuffer
ProtonNettyByteBuffer. readBytes(ProtonBuffer destination, int offset, int length)
ProtonBuffer
ProtonAbstractBuffer. setBytes(int index, ProtonBuffer source)
ProtonBuffer
ProtonAbstractBuffer. setBytes(int index, ProtonBuffer source, int length)
ProtonBuffer
ProtonBuffer. setBytes(int index, ProtonBuffer source)
Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex
until the source buffer becomes unreadable.ProtonBuffer
ProtonBuffer. setBytes(int index, ProtonBuffer source, int length)
Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex
.ProtonBuffer
ProtonBuffer. setBytes(int index, ProtonBuffer source, int offset, int length)
Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex
.ProtonBuffer
ProtonByteBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonCompositeBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonDuplicatedBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value, int length)
ProtonBuffer
ProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value, int offset, int length)
ProtonBuffer
ProtonNioByteBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, ProtonBuffer source)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, ProtonBuffer source, int length)
ProtonBuffer
ProtonSlicedBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(ProtonBuffer source)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(ProtonBuffer source, int length)
ProtonBuffer
ProtonAbstractBuffer. writeBytes(ProtonBuffer source, int offset, int length)
ProtonBuffer
ProtonBuffer. writeBytes(ProtonBuffer source)
Transfers the specified source buffer's data to this buffer starting at the currentwriteIndex
until the source buffer becomes unreadable, and increases thewriteIndex
by the number of the transferred bytes.ProtonBuffer
ProtonBuffer. writeBytes(ProtonBuffer source, int length)
Transfers the specified source buffer's data to this buffer starting at the currentwriteIndex
and increases thewriteIndex
by the number of the transferred bytes (=length
).ProtonBuffer
ProtonBuffer. writeBytes(ProtonBuffer source, int offset, int length)
Transfers the specified source buffer's data to this buffer starting at the currentwriteIndex
and increases thewriteIndex
by the number of the transferred bytes (=length
).ProtonBuffer
ProtonNettyByteBuffer. writeBytes(ProtonBuffer value)
ProtonBuffer
ProtonNettyByteBuffer. writeBytes(ProtonBuffer value, int length)
ProtonBuffer
ProtonNettyByteBuffer. writeBytes(ProtonBuffer value, int offset, int length)
Method parameters in org.apache.qpid.protonj2.buffer with type arguments of type ProtonBuffer Modifier and Type Method Description ProtonCompositeBuffer
ProtonCompositeBuffer. foreachBuffer(java.util.function.Consumer<ProtonBuffer> consumer)
For each of the buffers contained in thisProtonCompositeBuffer
instance the given consumer will be invoked with a duplicate of the buffer that can be independently modified and not affect the contents of this buffer.ProtonCompositeBuffer
ProtonCompositeBuffer. foreachInternalBuffer(java.util.function.Consumer<ProtonBuffer> consumer)
For each of the buffers contained in thisProtonCompositeBuffer
instance the given consumer will be invoked with theProtonBuffer
that backs this composite instance.Constructors in org.apache.qpid.protonj2.buffer with parameters of type ProtonBuffer Constructor Description ProtonBufferInputStream(ProtonBuffer buffer)
Creates a newInputStream
instance that wraps the givenProtonBuffer
ProtonBufferOutputStream(ProtonBuffer buffer)
Create a newOutputStream
which wraps the given buffer. -
Uses of ProtonBuffer in org.apache.qpid.protonj2.client
Methods in org.apache.qpid.protonj2.client that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
AdvancedMessage. encode(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
Encodes theAdvancedMessage
for transmission by the client. -
Uses of ProtonBuffer in org.apache.qpid.protonj2.client.impl
Methods in org.apache.qpid.protonj2.client.impl that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
ClientMessage. encode(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
ProtonBuffer
ClientStreamReceiverMessage. encode(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer
ClientMessageSupport. encodeMessage(AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer
ClientMessageSupport. encodeMessage(Encoder encoder, ProtonBufferAllocator allocator, AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer
ClientMessageSupport. encodeMessage(Encoder encoder, EncoderState encoderState, ProtonBufferAllocator allocator, AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer
ClientMessageSupport. encodeSection(Section<?> section, ProtonBuffer buffer)
ProtonBuffer
ClientOutgoingEnvelope. payload()
Methods in org.apache.qpid.protonj2.client.impl with parameters of type ProtonBuffer Modifier and Type Method Description static Message<?>
ClientMessageSupport. decodeMessage(ProtonBuffer buffer, java.util.function.Consumer<DeliveryAnnotations> daConsumer)
static Message<?>
ClientMessageSupport. decodeMessage(Decoder decoder, ProtonBuffer buffer, java.util.function.Consumer<DeliveryAnnotations> daConsumer)
static Message<?>
ClientMessageSupport. decodeMessage(Decoder decoder, DecoderState decoderState, ProtonBuffer buffer, java.util.function.Consumer<DeliveryAnnotations> daConsumer)
static ProtonBuffer
ClientMessageSupport. encodeSection(Section<?> section, ProtonBuffer buffer)
Constructors in org.apache.qpid.protonj2.client.impl with parameters of type ProtonBuffer Constructor Description ClientOutgoingEnvelope(org.apache.qpid.protonj2.client.impl.ClientSender sender, OutgoingDelivery delivery, int messageFormat, ProtonBuffer payload, boolean complete, ClientFuture<Tracker> request)
Create a new In-flight Send instance that is a continuation on an existing delivery. -
Uses of ProtonBuffer in org.apache.qpid.protonj2.client.transport
Methods in org.apache.qpid.protonj2.client.transport with parameters of type ProtonBuffer Modifier and Type Method Description protected io.netty.buffer.ByteBuf
TcpTransport. toOutputBuffer(ProtonBuffer output)
void
TransportListener. transportRead(ProtonBuffer incoming)
Called when new incoming data has become available for processing by theTransport
user.TcpTransport
TcpTransport. write(ProtonBuffer output)
TcpTransport
TcpTransport. write(ProtonBuffer output, java.lang.Runnable onComplete)
Transport
Transport. write(ProtonBuffer output)
Writes a chunk of data over the Transport connection without performing an explicit flush on the transport.Transport
Transport. write(ProtonBuffer output, java.lang.Runnable ioComplete)
Writes a chunk of data over the Transport connection without performing an explicit flush on the transport.WebSocketTransport
WebSocketTransport. write(ProtonBuffer output, java.lang.Runnable onComplete)
TcpTransport
TcpTransport. writeAndFlush(ProtonBuffer output)
TcpTransport
TcpTransport. writeAndFlush(ProtonBuffer output, java.lang.Runnable onComplete)
Transport
Transport. writeAndFlush(ProtonBuffer output)
Writes a chunk of data over the Transport connection and requests a flush of all pending queued write operationsTransport
Transport. writeAndFlush(ProtonBuffer output, java.lang.Runnable ioComplete)
Writes a chunk of data over the Transport connection and requests a flush of all pending queued write operationsWebSocketTransport
WebSocketTransport. writeAndFlush(ProtonBuffer output, java.lang.Runnable onComplete)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec
Methods in org.apache.qpid.protonj2.codec that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
EncoderState. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)
Encodes the given sequence of characters in UTF8 to the given buffer.ProtonBuffer
Decoder. readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)
Reads an encodedBinary
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.ProtonBuffer
StreamDecoder. readBinaryAsBuffer(java.io.InputStream stream, StreamDecoderState state)
Reads an encodedBinary
value from the givenInputStream
assuming that the next value in the byte stream is that type.Methods in org.apache.qpid.protonj2.codec with parameters of type ProtonBuffer Modifier and Type Method Description java.lang.String
DecoderState. decodeUTF8(ProtonBuffer buffer, int length)
Given a set of UTF-8 encoded bytes decode and return the String that represents that UTF-8 value.ProtonBuffer
EncoderState. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)
Encodes the given sequence of characters in UTF8 to the given buffer.TypeDecoder<?>
Decoder. peekNextTypeDecoder(ProtonBuffer buffer, DecoderState state)
Peeks ahead in the givenProtonBuffer
instance and returns aTypeDecoder
that can read the next encoded AMQP type from the buffer's bytes.V[]
TypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Reads a series of this type that have been encoded into the body of an Array type.Binary
Decoder. readBinary(ProtonBuffer buffer, DecoderState state)
Reads an encodedBinary
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.ProtonBuffer
Decoder. readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)
Reads an encodedBinary
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.Boolean
Decoder. readBoolean(ProtonBuffer buffer, DecoderState state)
Reads an encodedBoolean
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.boolean
Decoder. readBoolean(ProtonBuffer buffer, DecoderState state, boolean defaultValue)
Reads an encodedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.Byte
Decoder. readByte(ProtonBuffer buffer, DecoderState state)
Reads an encodedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.byte
Decoder. readByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)
Reads an encodedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.Character
Decoder. readCharacter(ProtonBuffer buffer, DecoderState state)
Reads an encodedCharacter
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.char
Decoder. readCharacter(ProtonBuffer buffer, DecoderState state, char defaultValue)
Reads an encodedCharacter
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.Decimal128
Decoder. readDecimal128(ProtonBuffer buffer, DecoderState state)
Reads an encodedDecimal128
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.Decimal32
Decoder. readDecimal32(ProtonBuffer buffer, DecoderState state)
Reads an encodedDecimal32
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.Decimal64
Decoder. readDecimal64(ProtonBuffer buffer, DecoderState state)
Reads an encodedDecimal64
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.DeliveryTag
Decoder. readDeliveryTag(ProtonBuffer buffer, DecoderState state)
This method expects to read aBinary
encoded type from the provided buffer and constructs aDeliveryTag
type that wraps the bytes encoded.java.lang.Double
Decoder. readDouble(ProtonBuffer buffer, DecoderState state)
Reads an encodedDouble
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.double
Decoder. readDouble(ProtonBuffer buffer, DecoderState state, double defaultValue)
Reads an encodedDouble
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.Float
Decoder. readFloat(ProtonBuffer buffer, DecoderState state)
Reads an encodedFloat
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.float
Decoder. readFloat(ProtonBuffer buffer, DecoderState state, float defaultValue)
Reads an encodedFloat
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.Integer
Decoder. readInteger(ProtonBuffer buffer, DecoderState state)
Reads an encodedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.int
Decoder. readInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)
Reads an encodedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.<V> java.util.List<V>
Decoder. readList(ProtonBuffer buffer, DecoderState state)
Reads an encodedList
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.Long
Decoder. readLong(ProtonBuffer buffer, DecoderState state)
Reads an encodedLong
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.long
Decoder. readLong(ProtonBuffer buffer, DecoderState state, long defaultValue)
Reads an encodedLong
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.<K,V>
java.util.Map<K,V>Decoder. readMap(ProtonBuffer buffer, DecoderState state)
Reads an encodedMap
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.<T> T[]
Decoder. readMultiple(ProtonBuffer buffer, DecoderState state, java.lang.Class<T> clazz)
Reads one or more encoded values from the givenProtonBuffer
an return it as an array ofObject
instances which the caller must then interpret.TypeDecoder<?>
Decoder. readNextTypeDecoder(ProtonBuffer buffer, DecoderState state)
Reads from the givenProtonBuffer
instance and returns aTypeDecoder
that can read the next encoded AMQP type from the buffer's bytes.java.lang.Object
Decoder. readObject(ProtonBuffer buffer, DecoderState state)
Reads an encoded value from the givenProtonBuffer
an return it as anObject
which the caller must then interpret.<T> T
Decoder. readObject(ProtonBuffer buffer, DecoderState state, java.lang.Class<T> clazz)
Reads an encoded value from the givenProtonBuffer
an return it as anObject
which the caller must then interpret.java.lang.Short
Decoder. readShort(ProtonBuffer buffer, DecoderState state)
Reads an encodedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.short
Decoder. readShort(ProtonBuffer buffer, DecoderState state, short defaultValue)
Reads an encodedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.String
Decoder. readString(ProtonBuffer buffer, DecoderState state)
Reads an encodedString
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.Symbol
Decoder. readSymbol(ProtonBuffer buffer, DecoderState state)
Reads an encodedSymbol
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.String
Decoder. readSymbol(ProtonBuffer buffer, DecoderState state, java.lang.String defaultValue)
Reads an encodedString
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.lang.Long
Decoder. readTimestamp(ProtonBuffer buffer, DecoderState state)
Reads an encoded AMQP time stamp value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.long
Decoder. readTimestamp(ProtonBuffer buffer, DecoderState state, long defaultValue)
Reads an encoded AMQP time stamp value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.UnsignedByte
Decoder. readUnsignedByte(ProtonBuffer buffer, DecoderState state)
Reads an encodedUnsignedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.byte
Decoder. readUnsignedByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)
Reads an encodedUnsignedByte
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.UnsignedInteger
Decoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state)
Reads an encodedUnsignedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.int
Decoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)
Reads an encodedUnsignedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.long
Decoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state, long defaultValue)
Reads an encodedUnsignedInteger
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.UnsignedLong
Decoder. readUnsignedLong(ProtonBuffer buffer, DecoderState state)
Reads an encodedUnsignedLong
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.long
Decoder. readUnsignedLong(ProtonBuffer buffer, DecoderState state, long defaultValue)
Reads an encodedUnsignedLong
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.UnsignedShort
Decoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state)
Reads an encodedUnsignedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.int
Decoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state, int defaultValue)
Reads an encodedUnsignedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.short
Decoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state, short defaultValue)
Reads an encodedUnsignedShort
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.java.util.UUID
Decoder. readUUID(ProtonBuffer buffer, DecoderState state)
Reads an encodedUUID
value from the givenProtonBuffer
assuming that the next value in the byte stream is that type.V
TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Reads the next type from the given buffer and returns it.void
TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
Skips over the bytes that compose the type this descriptor decodes.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, boolean[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, byte[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, char[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, double[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, float[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, int[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, long[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, short[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, java.util.UUID[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal128[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal32[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal64[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, Symbol[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedByte[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedInteger[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedLong[] value)
Write the given array as with the proper array type encoding to the given buffer.void
Encoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedShort[] value)
Write the given array as with the proper array type encoding to the given buffer.void
TypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
Write an array elements of the AMQP type to the given byte buffer.void
Encoder. writeBinary(ProtonBuffer buffer, EncoderState state, byte[] value)
Writes the contents of the givenbyte
value into the providedProtonBuffer
instance as an AMQP Binary type.void
Encoder. writeBinary(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)
Writes the contents of the givenProtonBuffer
value into the providedProtonBuffer
instance as an AMQP Binary type.void
Encoder. writeBinary(ProtonBuffer buffer, EncoderState state, Binary value)
Writes the contents of the givenBinary
value into the providedProtonBuffer
instance as an AMQP Binary type.void
Encoder. writeBoolean(ProtonBuffer buffer, EncoderState state, boolean value)
Write aBoolean
type encoding to the given buffer.void
Encoder. writeBoolean(ProtonBuffer buffer, EncoderState state, java.lang.Boolean value)
Write aBoolean
type encoding to the given buffer.void
Encoder. writeByte(ProtonBuffer buffer, EncoderState state, byte value)
Write aByte
type encoding to the given buffer.void
Encoder. writeByte(ProtonBuffer buffer, EncoderState state, java.lang.Byte value)
Write aByte
type encoding to the given buffer.void
Encoder. writeCharacter(ProtonBuffer buffer, EncoderState state, char value)
Write aCharacter
type encoding to the given buffer.void
Encoder. writeCharacter(ProtonBuffer buffer, EncoderState state, java.lang.Character value)
Write aCharacter
type encoding to the given buffer.void
Encoder. writeDecimal128(ProtonBuffer buffer, EncoderState state, Decimal128 value)
Write aDecimal128
type encoding to the given buffer.void
Encoder. writeDecimal32(ProtonBuffer buffer, EncoderState state, Decimal32 value)
Write aDecimal32
type encoding to the given buffer.void
Encoder. writeDecimal64(ProtonBuffer buffer, EncoderState state, Decimal64 value)
Write aDecimal64
type encoding to the given buffer.void
Encoder. writeDeliveryTag(ProtonBuffer buffer, EncoderState state, DeliveryTag value)
Writes the contents of the givenDeliveryTag
value into the providedProtonBuffer
instance as an AMQP Binary type.void
Encoder. writeDescribedType(ProtonBuffer buffer, EncoderState state, DescribedType value)
Write aDescribedType
type encoding to the given buffer.void
Encoder. writeDouble(ProtonBuffer buffer, EncoderState state, double value)
Write aDouble
type encoding to the given buffer.void
Encoder. writeDouble(ProtonBuffer buffer, EncoderState state, java.lang.Double value)
Write aDouble
type encoding to the given buffer.void
Encoder. writeFloat(ProtonBuffer buffer, EncoderState state, float value)
Write aFloat
type encoding to the given buffer.void
Encoder. writeFloat(ProtonBuffer buffer, EncoderState state, java.lang.Float value)
Write aFloat
type encoding to the given buffer.void
Encoder. writeInteger(ProtonBuffer buffer, EncoderState state, int value)
Write aInteger
type encoding to the given buffer.void
Encoder. writeInteger(ProtonBuffer buffer, EncoderState state, java.lang.Integer value)
Write aInteger
type encoding to the given buffer.<T> void
Encoder. writeList(ProtonBuffer buffer, EncoderState state, java.util.List<T> value)
Write aList
type encoding to the given buffer.void
Encoder. writeLong(ProtonBuffer buffer, EncoderState state, long value)
Write aLong
type encoding to the given buffer.void
Encoder. writeLong(ProtonBuffer buffer, EncoderState state, java.lang.Long value)
Write aLong
type encoding to the given buffer.<K,V>
voidEncoder. writeMap(ProtonBuffer buffer, EncoderState state, java.util.Map<K,V> value)
Write aMap
type encoding to the given buffer.void
Encoder. writeNull(ProtonBuffer buffer, EncoderState state)
Write a Null type encoding to the given buffer.void
Encoder. writeObject(ProtonBuffer buffer, EncoderState state, java.lang.Object value)
Write the proper type encoding for the providedObject
to the given buffer if anTypeEncoder
can be found for it in the collection of registered type encoders..void
TypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
Write an array elements of the AMQP type to the given byte buffer.void
Encoder. writeShort(ProtonBuffer buffer, EncoderState state, short value)
Write aShort
type encoding to the given buffer.void
Encoder. writeShort(ProtonBuffer buffer, EncoderState state, java.lang.Short value)
Write aShort
type encoding to the given buffer.void
Encoder. writeString(ProtonBuffer buffer, EncoderState state, java.lang.String value)
Write aString
type encoding to the given buffer.void
Encoder. writeSymbol(ProtonBuffer buffer, EncoderState state, java.lang.String value)
Write aSymbol
type encoding to the given buffer.void
Encoder. writeSymbol(ProtonBuffer buffer, EncoderState state, Symbol value)
Write aSymbol
type encoding to the given buffer.void
Encoder. writeTimestamp(ProtonBuffer buffer, EncoderState state, long value)
Write a Time stamp type encoding to the given buffer.void
Encoder. writeTimestamp(ProtonBuffer buffer, EncoderState state, java.util.Date value)
Write a Time stamp type encoding to the given buffer.void
TypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, V value)
Write the full AMQP type data to the given byte buffer.void
Encoder. writeUnsignedByte(ProtonBuffer buffer, EncoderState state, byte value)
Write anUnsignedByte
type encoding to the given buffer.void
Encoder. writeUnsignedByte(ProtonBuffer buffer, EncoderState state, UnsignedByte value)
Write anUnsignedByte
type encoding to the given buffer.void
Encoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, byte value)
Write aUnsignedInteger
type encoding to the given buffer.void
Encoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, int value)
Write aUnsignedInteger
type encoding to the given buffer.void
Encoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, long value)
Write aUnsignedInteger
type encoding to the given buffer using the provided value with appropriate range checks to ensure invalid input is not accepted.void
Encoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)
Write aUnsignedInteger
type encoding to the given buffer.void
Encoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, byte value)
Write aUnsignedLong
type encoding to the given buffer.void
Encoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, long value)
Write aUnsignedLong
type encoding to the given buffer.void
Encoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, UnsignedLong value)
Write aUnsignedLong
type encoding to the given buffer.void
Encoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, int value)
Write aUnsignedShort
type encoding to the given buffer using the provided value with appropriate range checks to ensure invalid input is not accepted.void
Encoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, short value)
Write aUnsignedShort
type encoding to the given buffer.void
Encoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, UnsignedShort value)
Write aUnsignedShort
type encoding to the given buffer.void
Encoder. writeUUID(ProtonBuffer buffer, EncoderState state, java.util.UUID value)
Write aUUID
type encoding to the given buffer. -
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders
Methods in org.apache.qpid.protonj2.codec.decoders that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
ProtonDecoder. readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)
ProtonBuffer
ProtonStreamDecoder. readBinaryAsBuffer(java.io.InputStream stream, StreamDecoderState state)
Methods in org.apache.qpid.protonj2.codec.decoders with parameters of type ProtonBuffer Modifier and Type Method Description java.lang.String
ProtonDecoderState. decodeUTF8(ProtonBuffer buffer, int length)
java.lang.String
UTF8Decoder. decodeUTF8(ProtonBuffer buffer, int utf8length)
Decodes a String from the given UTF8 Bytes advancing the buffer read index by the given length value once complete.TypeDecoder<?>
ProtonDecoder. peekNextTypeDecoder(ProtonBuffer buffer, DecoderState state)
V[]
AbstractPrimitiveTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DescribedType[]
UnknownDescribedTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Binary
ProtonDecoder. readBinary(ProtonBuffer buffer, DecoderState state)
ProtonBuffer
ProtonDecoder. readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)
java.lang.Boolean
ProtonDecoder. readBoolean(ProtonBuffer buffer, DecoderState state)
boolean
ProtonDecoder. readBoolean(ProtonBuffer buffer, DecoderState state, boolean defaultValue)
java.lang.Byte
ProtonDecoder. readByte(ProtonBuffer buffer, DecoderState state)
byte
ProtonDecoder. readByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)
java.lang.Character
ProtonDecoder. readCharacter(ProtonBuffer buffer, DecoderState state)
char
ProtonDecoder. readCharacter(ProtonBuffer buffer, DecoderState state, char defaultValue)
Decimal128
ProtonDecoder. readDecimal128(ProtonBuffer buffer, DecoderState state)
Decimal32
ProtonDecoder. readDecimal32(ProtonBuffer buffer, DecoderState state)
Decimal64
ProtonDecoder. readDecimal64(ProtonBuffer buffer, DecoderState state)
DeliveryTag
ProtonDecoder. readDeliveryTag(ProtonBuffer buffer, DecoderState state)
java.lang.Double
ProtonDecoder. readDouble(ProtonBuffer buffer, DecoderState state)
double
ProtonDecoder. readDouble(ProtonBuffer buffer, DecoderState state, double defaultValue)
java.lang.Float
ProtonDecoder. readFloat(ProtonBuffer buffer, DecoderState state)
float
ProtonDecoder. readFloat(ProtonBuffer buffer, DecoderState state, float defaultValue)
java.lang.Integer
ProtonDecoder. readInteger(ProtonBuffer buffer, DecoderState state)
int
ProtonDecoder. readInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)
<V> java.util.List<V>
ProtonDecoder. readList(ProtonBuffer buffer, DecoderState state)
java.lang.Long
ProtonDecoder. readLong(ProtonBuffer buffer, DecoderState state)
long
ProtonDecoder. readLong(ProtonBuffer buffer, DecoderState state, long defaultValue)
<K,V>
java.util.Map<K,V>ProtonDecoder. readMap(ProtonBuffer buffer, DecoderState state)
<T> T[]
ProtonDecoder. readMultiple(ProtonBuffer buffer, DecoderState state, java.lang.Class<T> clazz)
TypeDecoder<?>
ProtonDecoder. readNextTypeDecoder(ProtonBuffer buffer, DecoderState state)
java.lang.Object
ProtonDecoder. readObject(ProtonBuffer buffer, DecoderState state)
<T> T
ProtonDecoder. readObject(ProtonBuffer buffer, DecoderState state, java.lang.Class<T> clazz)
java.lang.Short
ProtonDecoder. readShort(ProtonBuffer buffer, DecoderState state)
short
ProtonDecoder. readShort(ProtonBuffer buffer, DecoderState state, short defaultValue)
java.lang.String
ProtonDecoder. readString(ProtonBuffer buffer, DecoderState state)
Symbol
ProtonDecoder. readSymbol(ProtonBuffer buffer, DecoderState state)
java.lang.String
ProtonDecoder. readSymbol(ProtonBuffer buffer, DecoderState state, java.lang.String defaultValue)
java.lang.Long
ProtonDecoder. readTimestamp(ProtonBuffer buffer, DecoderState state)
long
ProtonDecoder. readTimestamp(ProtonBuffer buffer, DecoderState state, long defaultValue)
UnsignedByte
ProtonDecoder. readUnsignedByte(ProtonBuffer buffer, DecoderState state)
byte
ProtonDecoder. readUnsignedByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)
UnsignedInteger
ProtonDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state)
int
ProtonDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)
long
ProtonDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state, long defaultValue)
UnsignedLong
ProtonDecoder. readUnsignedLong(ProtonBuffer buffer, DecoderState state)
long
ProtonDecoder. readUnsignedLong(ProtonBuffer buffer, DecoderState state, long defaultValue)
UnsignedShort
ProtonDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state)
int
ProtonDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state, int defaultValue)
short
ProtonDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state, short defaultValue)
java.util.UUID
ProtonDecoder. readUUID(ProtonBuffer buffer, DecoderState state)
DescribedType
UnknownDescribedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
void
UnknownDescribedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.messaging
Methods in org.apache.qpid.protonj2.codec.decoders.messaging with parameters of type ProtonBuffer Modifier and Type Method Description Accepted[]
AcceptedTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
AmqpSequence[]
AmqpSequenceTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
AmqpValue[]
AmqpValueTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
ApplicationProperties[]
ApplicationPropertiesTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Data[]
DataTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeleteOnClose[]
DeleteOnCloseTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeleteOnNoLinksOrMessages[]
DeleteOnNoLinksOrMessagesTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeleteOnNoLinks[]
DeleteOnNoLinksTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeleteOnNoMessages[]
DeleteOnNoMessagesTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeliveryAnnotations[]
DeliveryAnnotationsTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Footer[]
FooterTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Header[]
HeaderTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
MessageAnnotations[]
MessageAnnotationsTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Modified[]
ModifiedTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Properties[]
PropertiesTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Received[]
ReceivedTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Rejected[]
RejectedTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Released[]
ReleasedTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Source[]
SourceTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Target[]
TargetTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Accepted
AcceptedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
AmqpSequence<?>
AmqpSequenceTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
AmqpValue<?>
AmqpValueTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
ApplicationProperties
ApplicationPropertiesTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Data
DataTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
DeleteOnClose
DeleteOnCloseTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
DeleteOnNoLinksOrMessages
DeleteOnNoLinksOrMessagesTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
DeleteOnNoLinks
DeleteOnNoLinksTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
DeleteOnNoMessages
DeleteOnNoMessagesTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
DeliveryAnnotations
DeliveryAnnotationsTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Footer
FooterTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Header
HeaderTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
MessageAnnotations
MessageAnnotationsTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Modified
ModifiedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Properties
PropertiesTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Received
ReceivedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Rejected
RejectedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Released
ReleasedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Source
SourceTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Target
TargetTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
void
AcceptedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
AmqpSequenceTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
AmqpValueTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
ApplicationPropertiesTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DataTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DeleteOnCloseTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DeleteOnNoLinksOrMessagesTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DeleteOnNoLinksTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DeleteOnNoMessagesTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DeliveryAnnotationsTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
FooterTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
HeaderTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
MessageAnnotationsTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
ModifiedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
PropertiesTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
ReceivedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
RejectedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
ReleasedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
SourceTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
TargetTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.primitives
Methods in org.apache.qpid.protonj2.codec.decoders.primitives that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
AbstractBinaryTypeDecoder. readValueAsBuffer(java.io.InputStream stream, StreamDecoderState state)
Read and decode an AMQPBinary
into aProtonBuffer
instance and return it.ProtonBuffer
AbstractBinaryTypeDecoder. readValueAsBuffer(ProtonBuffer buffer, DecoderState state)
Read and decode an AMQPBinary
into aProtonBuffer
instance and return it.Methods in org.apache.qpid.protonj2.codec.decoders.primitives with parameters of type ProtonBuffer Modifier and Type Method Description protected abstract int
AbstractArrayTypeDecoder. readCount(ProtonBuffer buffer)
protected int
Array32TypeDecoder. readCount(ProtonBuffer buffer)
protected int
Array8TypeDecoder. readCount(ProtonBuffer buffer)
int
List0TypeDecoder. readCount(ProtonBuffer buffer)
int
List32TypeDecoder. readCount(ProtonBuffer buffer)
int
List8TypeDecoder. readCount(ProtonBuffer buffer)
int
ListTypeDecoder. readCount(ProtonBuffer buffer)
Reads the number of elements contained in the encoded list from the providedProtonBuffer
.int
Map32TypeDecoder. readCount(ProtonBuffer buffer)
int
Map8TypeDecoder. readCount(ProtonBuffer buffer)
int
MapTypeDecoder. readCount(ProtonBuffer buffer)
Reads the count of entries in the encoded Map.boolean
BooleanFalseTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
boolean
BooleanTrueTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
boolean
BooleanTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.byte
ByteTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.char
CharacterTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.double
DoubleTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.float
FloatTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.int
Integer32TypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.int
Integer8TypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.long
Long8TypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
long
LongTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.short
ShortTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
Reads the primitive value from the givenProtonBuffer
and returns it.protected abstract int
AbstractArrayTypeDecoder. readSize(ProtonBuffer buffer)
abstract int
AbstractBinaryTypeDecoder. readSize(ProtonBuffer buffer)
protected abstract int
AbstractStringTypeDecoder. readSize(ProtonBuffer buffer)
protected abstract int
AbstractSymbolTypeDecoder. readSize(ProtonBuffer buffer)
Subclasses must read the correct number of bytes from the buffer to determine the size of the encoded Symbol value.protected int
Array32TypeDecoder. readSize(ProtonBuffer buffer)
protected int
Array8TypeDecoder. readSize(ProtonBuffer buffer)
int
Binary32TypeDecoder. readSize(ProtonBuffer buffer)
int
Binary8TypeDecoder. readSize(ProtonBuffer buffer)
int
BinaryTypeDecoder. readSize(ProtonBuffer buffer)
Reads the encoded size value for the encoded binary payload and returns it.int
List0TypeDecoder. readSize(ProtonBuffer buffer)
int
List32TypeDecoder. readSize(ProtonBuffer buffer)
int
List8TypeDecoder. readSize(ProtonBuffer buffer)
int
ListTypeDecoder. readSize(ProtonBuffer buffer)
Reads the size in bytes of the encoded list from the providedProtonBuffer
.int
Map32TypeDecoder. readSize(ProtonBuffer buffer)
int
Map8TypeDecoder. readSize(ProtonBuffer buffer)
int
MapTypeDecoder. readSize(ProtonBuffer buffer)
Reads the encoded size of the underlying Map type.protected int
String32TypeDecoder. readSize(ProtonBuffer buffer)
protected int
String8TypeDecoder. readSize(ProtonBuffer buffer)
protected int
Symbol32TypeDecoder. readSize(ProtonBuffer buffer)
protected int
Symbol8TypeDecoder. readSize(ProtonBuffer buffer)
java.lang.String
AbstractSymbolTypeDecoder. readString(ProtonBuffer buffer, DecoderState state)
Reads a String view of an encoded Symbol value from the given buffer.java.lang.Object
AbstractArrayTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Binary
AbstractBinaryTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.util.List<java.lang.Object>
AbstractListTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.util.Map<java.lang.Object,java.lang.Object>
AbstractMapTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.String
AbstractStringTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Symbol
AbstractSymbolTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Boolean
BooleanFalseTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Boolean
BooleanTrueTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Boolean
BooleanTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Byte
ByteTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Character
CharacterTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Decimal128
Decimal128TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Decimal32
Decimal32TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Decimal64
Decimal64TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Double
DoubleTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Float
FloatTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Integer
Integer32TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Integer
Integer8TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.util.List<java.lang.Object>
List0TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Long
Long8TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Long
LongTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Void
NullTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Short
ShortTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.lang.Long
TimestampTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
UnsignedByte
UnsignedByteTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
UnsignedInteger
UnsignedInteger0TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
UnsignedInteger
UnsignedInteger32TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
UnsignedInteger
UnsignedInteger8TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
UnsignedLong
UnsignedLong0TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
UnsignedLong
UnsignedLong64TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
UnsignedLong
UnsignedLong8TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
UnsignedShort
UnsignedShortTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
java.util.UUID
UUIDTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
byte[]
AbstractBinaryTypeDecoder. readValueAsArray(ProtonBuffer buffer, DecoderState state)
Read and decode an AMQPBinary
into a byte array instance and return it.ProtonBuffer
AbstractBinaryTypeDecoder. readValueAsBuffer(ProtonBuffer buffer, DecoderState state)
Read and decode an AMQPBinary
into aProtonBuffer
instance and return it.void
AbstractArrayTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
AbstractBinaryTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
AbstractListTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
AbstractMapTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
AbstractStringTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
AbstractSymbolTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
BooleanFalseTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
BooleanTrueTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
BooleanTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
ByteTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
CharacterTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
Decimal128TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
Decimal32TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
Decimal64TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DoubleTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
FloatTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
Integer32TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
Integer8TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
List0TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
Long8TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
LongTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
NullTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
ShortTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
TimestampTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UnsignedByteTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UnsignedInteger0TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UnsignedInteger32TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UnsignedInteger8TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UnsignedLong0TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UnsignedLong64TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UnsignedLong8TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UnsignedShortTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
UUIDTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.security
Methods in org.apache.qpid.protonj2.codec.decoders.security with parameters of type ProtonBuffer Modifier and Type Method Description SaslChallenge[]
SaslChallengeTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslInit[]
SaslInitTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslMechanisms[]
SaslMechanismsTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslOutcome[]
SaslOutcomeTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslResponse[]
SaslResponseTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslChallenge
SaslChallengeTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
SaslInit
SaslInitTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
SaslMechanisms
SaslMechanismsTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
SaslOutcome
SaslOutcomeTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
SaslResponse
SaslResponseTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
void
SaslChallengeTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
SaslInitTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
SaslMechanismsTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
SaslOutcomeTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
SaslResponseTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.transactions
Methods in org.apache.qpid.protonj2.codec.decoders.transactions with parameters of type ProtonBuffer Modifier and Type Method Description Coordinator[]
CoordinatorTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Declared[]
DeclaredTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Declare[]
DeclareTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Discharge[]
DischargeTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
TransactionalState[]
TransactionStateTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Coordinator
CoordinatorTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Declared
DeclaredTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Declare
DeclareTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Discharge
DischargeTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
TransactionalState
TransactionStateTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
void
CoordinatorTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DeclaredTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DeclareTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DischargeTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
TransactionStateTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.transport
Methods in org.apache.qpid.protonj2.codec.decoders.transport with parameters of type ProtonBuffer Modifier and Type Method Description Attach[]
AttachTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Begin[]
BeginTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Close[]
CloseTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Detach[]
DetachTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Disposition[]
DispositionTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
End[]
EndTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
ErrorCondition[]
ErrorConditionTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Flow[]
FlowTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Open[]
OpenTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Transfer[]
TransferTypeDecoder. readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Attach
AttachTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Begin
BeginTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Close
CloseTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Detach
DetachTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Disposition
DispositionTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
End
EndTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
ErrorCondition
ErrorConditionTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Flow
FlowTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Open
OpenTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
Transfer
TransferTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)
void
AttachTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
BeginTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
CloseTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DetachTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
DispositionTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
EndTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
ErrorConditionTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
FlowTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
OpenTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
void
TransferTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders
Methods in org.apache.qpid.protonj2.codec.encoders that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
ProtonEncoderState. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)
ProtonBuffer
UTF8Encoder. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)
Encodes the given sequence of characters in UTF8 to the given buffer.Methods in org.apache.qpid.protonj2.codec.encoders with parameters of type ProtonBuffer Modifier and Type Method Description ProtonBuffer
ProtonEncoderState. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)
ProtonBuffer
UTF8Encoder. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)
Encodes the given sequence of characters in UTF8 to the given buffer.void
AbstractDescribedListTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
AbstractDescribedMapTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
AbstractPrimitiveTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
DeliveryTagEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, boolean[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, byte[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, char[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, double[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, float[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, int[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, long[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, short[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.util.UUID[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal128[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal32[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal64[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Symbol[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedByte[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedInteger[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedLong[] value)
void
ProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedShort[] value)
void
UnknownDescribedTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] value)
void
ProtonEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, byte[] value)
void
ProtonEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)
void
ProtonEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, Binary value)
void
ProtonEncoder. writeBoolean(ProtonBuffer buffer, EncoderState state, boolean value)
void
ProtonEncoder. writeBoolean(ProtonBuffer buffer, EncoderState state, java.lang.Boolean value)
void
ProtonEncoder. writeByte(ProtonBuffer buffer, EncoderState state, byte value)
void
ProtonEncoder. writeByte(ProtonBuffer buffer, EncoderState state, java.lang.Byte value)
void
ProtonEncoder. writeCharacter(ProtonBuffer buffer, EncoderState state, char value)
void
ProtonEncoder. writeCharacter(ProtonBuffer buffer, EncoderState state, java.lang.Character value)
void
ProtonEncoder. writeDecimal128(ProtonBuffer buffer, EncoderState state, Decimal128 value)
void
ProtonEncoder. writeDecimal32(ProtonBuffer buffer, EncoderState state, Decimal32 value)
void
ProtonEncoder. writeDecimal64(ProtonBuffer buffer, EncoderState state, Decimal64 value)
void
ProtonEncoder. writeDeliveryTag(ProtonBuffer buffer, EncoderState state, DeliveryTag value)
void
ProtonEncoder. writeDescribedType(ProtonBuffer buffer, EncoderState state, DescribedType value)
void
ProtonEncoder. writeDouble(ProtonBuffer buffer, EncoderState state, double value)
void
ProtonEncoder. writeDouble(ProtonBuffer buffer, EncoderState state, java.lang.Double value)
abstract void
AbstractDescribedListTypeEncoder. writeElement(V source, int index, ProtonBuffer buffer, EncoderState state)
Instructs the encoder to write the element identified with the given indexvoid
ProtonEncoder. writeFloat(ProtonBuffer buffer, EncoderState state, float value)
void
ProtonEncoder. writeFloat(ProtonBuffer buffer, EncoderState state, java.lang.Float value)
void
ProtonEncoder. writeInteger(ProtonBuffer buffer, EncoderState state, int value)
void
ProtonEncoder. writeInteger(ProtonBuffer buffer, EncoderState state, java.lang.Integer value)
<T> void
ProtonEncoder. writeList(ProtonBuffer buffer, EncoderState state, java.util.List<T> value)
void
ProtonEncoder. writeLong(ProtonBuffer buffer, EncoderState state, long value)
void
ProtonEncoder. writeLong(ProtonBuffer buffer, EncoderState state, java.lang.Long value)
<K,V>
voidProtonEncoder. writeMap(ProtonBuffer buffer, EncoderState state, java.util.Map<K,V> value)
abstract void
AbstractDescribedMapTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, M value)
Performs the write of the Map entries to the given buffer, the caller takes care of writing the Map preamble and tracking the final size of the written elements of the Map.void
ProtonEncoder. writeNull(ProtonBuffer buffer, EncoderState state)
void
ProtonEncoder. writeObject(ProtonBuffer buffer, EncoderState state, java.lang.Object value)
void
AbstractDescribedListTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
AbstractDescribedMapTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
DeliveryTagEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
UnknownDescribedTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
ProtonEncoder. writeShort(ProtonBuffer buffer, EncoderState state, short value)
void
ProtonEncoder. writeShort(ProtonBuffer buffer, EncoderState state, java.lang.Short value)
void
ProtonEncoder. writeString(ProtonBuffer buffer, EncoderState state, java.lang.String value)
void
ProtonEncoder. writeSymbol(ProtonBuffer buffer, EncoderState state, java.lang.String value)
void
ProtonEncoder. writeSymbol(ProtonBuffer buffer, EncoderState state, Symbol value)
void
ProtonEncoder. writeTimestamp(ProtonBuffer buffer, EncoderState state, long value)
void
ProtonEncoder. writeTimestamp(ProtonBuffer buffer, EncoderState state, java.util.Date value)
void
AbstractDescribedListTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, V value)
void
AbstractDescribedMapTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, M value)
void
DeliveryTagEncoder. writeType(ProtonBuffer buffer, EncoderState state, DeliveryTag value)
void
UnknownDescribedTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, DescribedType value)
void
ProtonEncoder. writeUnsignedByte(ProtonBuffer buffer, EncoderState state, byte value)
void
ProtonEncoder. writeUnsignedByte(ProtonBuffer buffer, EncoderState state, UnsignedByte value)
void
ProtonEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, byte value)
void
ProtonEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, int value)
void
ProtonEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, long value)
void
ProtonEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)
void
ProtonEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, byte value)
void
ProtonEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, long value)
void
ProtonEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, UnsignedLong value)
void
ProtonEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, int value)
void
ProtonEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, short value)
void
ProtonEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, UnsignedShort value)
void
ProtonEncoder. writeUUID(ProtonBuffer buffer, EncoderState state, java.util.UUID value)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.messaging
Methods in org.apache.qpid.protonj2.codec.encoders.messaging with parameters of type ProtonBuffer Modifier and Type Method Description void
AmqpSequenceTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
AmqpValueTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
DataTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
AcceptedTypeEncoder. writeElement(Accepted source, int index, ProtonBuffer buffer, EncoderState state)
void
DeleteOnCloseTypeEncoder. writeElement(DeleteOnClose source, int index, ProtonBuffer buffer, EncoderState state)
void
DeleteOnNoLinksOrMessagesTypeEncoder. writeElement(DeleteOnNoLinksOrMessages source, int index, ProtonBuffer buffer, EncoderState state)
void
DeleteOnNoLinksTypeEncoder. writeElement(DeleteOnNoLinks source, int index, ProtonBuffer buffer, EncoderState state)
void
DeleteOnNoMessagesTypeEncoder. writeElement(DeleteOnNoMessages source, int index, ProtonBuffer buffer, EncoderState state)
void
HeaderTypeEncoder. writeElement(Header header, int index, ProtonBuffer buffer, EncoderState state)
void
ModifiedTypeEncoder. writeElement(Modified source, int index, ProtonBuffer buffer, EncoderState state)
void
PropertiesTypeEncoder. writeElement(Properties properties, int index, ProtonBuffer buffer, EncoderState state)
void
ReceivedTypeEncoder. writeElement(Received source, int index, ProtonBuffer buffer, EncoderState state)
void
RejectedTypeEncoder. writeElement(Rejected source, int index, ProtonBuffer buffer, EncoderState state)
void
ReleasedTypeEncoder. writeElement(Released source, int index, ProtonBuffer buffer, EncoderState state)
void
SourceTypeEncoder. writeElement(Source source, int index, ProtonBuffer buffer, EncoderState state)
void
TargetTypeEncoder. writeElement(Target target, int index, ProtonBuffer buffer, EncoderState state)
void
ApplicationPropertiesTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, ApplicationProperties value)
void
DeliveryAnnotationsTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, DeliveryAnnotations value)
void
FooterTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, Footer value)
void
MessageAnnotationsTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, MessageAnnotations value)
void
AmqpSequenceTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
AmqpValueTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
DataTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
AcceptedTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Accepted value)
void
AmqpSequenceTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, AmqpSequence value)
void
AmqpValueTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, AmqpValue value)
void
DataTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Data value)
void
ReleasedTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Released value)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.primitives
Methods in org.apache.qpid.protonj2.codec.encoders.primitives with parameters of type ProtonBuffer Modifier and Type Method Description void
ArrayTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
BooleanTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, boolean[] values)
Write the full AMQP type data for the boolean array to the given byte buffer.void
ByteTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, byte[] values)
void
CharacterTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, char[] values)
void
DoubleTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, double[] values)
void
FloatTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, float[] values)
void
IntegerTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, int[] values)
void
LongTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, long[] values)
void
NullTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] value)
void
ShortTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, short[] values)
void
ArrayTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
BinaryTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
BooleanTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, boolean[] values)
Write the AMQP type data to the given byte buffer without an type encoding metadatavoid
BooleanTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
ByteTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, byte[] values)
void
ByteTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
CharacterTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, char[] values)
void
CharacterTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
Decimal128TypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
Decimal32TypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
Decimal64TypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
DoubleTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, double[] values)
void
DoubleTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
FloatTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, float[] values)
void
FloatTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
IntegerTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, int[] values)
void
IntegerTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
ListTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
LongTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, long[] values)
void
LongTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
MapTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
NullTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
ShortTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, short[] values)
void
ShortTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
StringTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
SymbolTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
TimestampTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
UnsignedByteTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
UnsignedIntegerTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
UnsignedLongTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
UnsignedShortTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
UUIDTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)
void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, boolean[] value)
Encodes the given array into the provided buffer for transmission.void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte[] value)
Encodes the given array into the provided buffer for transmission.void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, char[] value)
Encodes the given array into the provided buffer for transmission.void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, double[] value)
Encodes the given array into the provided buffer for transmission.void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, float[] value)
Encodes the given array into the provided buffer for transmission.void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, int[] value)
Encodes the given array into the provided buffer for transmission.void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long[] value)
Encodes the given array into the provided buffer for transmission.void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, short[] value)
Encodes the given array into the provided buffer for transmission.void
ArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Object value)
void
BinaryTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte[] value)
Shortcut API that allows abyte[]
to be directly encoded as an AMQP Binary type without the need to create aBinary
instance.void
BinaryTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)
Shortcut API that allows aProtonBuffer
to be directly encoded as an AMQP Binary type without the need to create aBinary
instance.void
BinaryTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Binary value)
void
BooleanTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, boolean value)
Write the full AMQP type data for the boolean to the given byte buffer.void
BooleanTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Boolean value)
void
ByteTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte value)
Write the full AMQP type data for the byte to the given byte buffer.void
ByteTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Byte value)
void
CharacterTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Character value)
void
Decimal128TypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Decimal128 value)
void
Decimal32TypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Decimal32 value)
void
Decimal64TypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Decimal64 value)
void
DoubleTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, double value)
Write the full AMQP type data for the double to the given byte buffer.void
DoubleTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Double value)
void
FloatTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, float value)
Write the full AMQP type data for the float to the given byte buffer.void
FloatTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Float value)
void
IntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, int value)
Write the full AMQP type data for the int to the given byte buffer.void
IntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Integer value)
void
ListTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.util.List value)
void
LongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long value)
Write the full AMQP type data for the long to the given byte buffer.void
LongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Long value)
void
MapTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.util.Map value)
void
NullTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Void value)
void
ShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, short value)
Write the full AMQP type data for the short to the given byte buffer.void
ShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Short value)
void
StringTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.String value)
void
SymbolTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Symbol value)
void
TimestampTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long value)
Write the full AMQP type data for the time-stamp to the given byte buffer.void
TimestampTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.util.Date value)
void
UnsignedByteTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte value)
Write the full AMQP type data for the byte to the given byte buffer.void
UnsignedByteTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, UnsignedByte value)
void
UnsignedIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte value)
Write the full AMQP type data for the unsigned int to the given byte buffer.void
UnsignedIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, int value)
Write the full AMQP type data for the unsigned int to the given byte buffer.void
UnsignedIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long value)
Write the full AMQP type data for the unsigned integer to the given byte buffer.void
UnsignedIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)
void
UnsignedLongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte value)
Write the full AMQP type data for the unsigned long to the given byte buffer.void
UnsignedLongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long value)
Write the full AMQP type data for the unsigned long to the given byte buffer.void
UnsignedLongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, UnsignedLong value)
void
UnsignedShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, int value)
Write the full AMQP type data for the unsigned short to the given byte buffer.void
UnsignedShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, short value)
Write the full AMQP type data for the unsigned short to the given byte buffer.void
UnsignedShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, UnsignedShort value)
void
UUIDTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.util.UUID value)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.security
Methods in org.apache.qpid.protonj2.codec.encoders.security with parameters of type ProtonBuffer Modifier and Type Method Description void
SaslChallengeTypeEncoder. writeElement(SaslChallenge challenge, int index, ProtonBuffer buffer, EncoderState state)
void
SaslInitTypeEncoder. writeElement(SaslInit init, int index, ProtonBuffer buffer, EncoderState state)
void
SaslMechanismsTypeEncoder. writeElement(SaslMechanisms mechanisms, int index, ProtonBuffer buffer, EncoderState state)
void
SaslOutcomeTypeEncoder. writeElement(SaslOutcome outcome, int index, ProtonBuffer buffer, EncoderState state)
void
SaslResponseTypeEncoder. writeElement(SaslResponse response, int index, ProtonBuffer buffer, EncoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.transactions
Methods in org.apache.qpid.protonj2.codec.encoders.transactions with parameters of type ProtonBuffer Modifier and Type Method Description void
CoordinatorTypeEncoder. writeElement(Coordinator coordinator, int index, ProtonBuffer buffer, EncoderState state)
void
DeclaredTypeEncoder. writeElement(Declared declared, int index, ProtonBuffer buffer, EncoderState state)
void
DeclareTypeEncoder. writeElement(Declare declare, int index, ProtonBuffer buffer, EncoderState state)
void
DischargeTypeEncoder. writeElement(Discharge discharge, int index, ProtonBuffer buffer, EncoderState state)
void
TransactionStateTypeEncoder. writeElement(TransactionalState txState, int index, ProtonBuffer buffer, EncoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.transport
Methods in org.apache.qpid.protonj2.codec.encoders.transport with parameters of type ProtonBuffer Modifier and Type Method Description void
AttachTypeEncoder. writeElement(Attach attach, int index, ProtonBuffer buffer, EncoderState state)
void
BeginTypeEncoder. writeElement(Begin begin, int index, ProtonBuffer buffer, EncoderState state)
void
CloseTypeEncoder. writeElement(Close close, int index, ProtonBuffer buffer, EncoderState state)
void
DetachTypeEncoder. writeElement(Detach detach, int index, ProtonBuffer buffer, EncoderState state)
void
DispositionTypeEncoder. writeElement(Disposition disposition, int index, ProtonBuffer buffer, EncoderState state)
void
EndTypeEncoder. writeElement(End end, int index, ProtonBuffer buffer, EncoderState state)
void
ErrorConditionTypeEncoder. writeElement(ErrorCondition error, int index, ProtonBuffer buffer, EncoderState state)
void
FlowTypeEncoder. writeElement(Flow flow, int index, ProtonBuffer buffer, EncoderState state)
void
OpenTypeEncoder. writeElement(Open open, int index, ProtonBuffer buffer, EncoderState state)
void
TransferTypeEncoder. writeElement(Transfer transfer, int index, ProtonBuffer buffer, EncoderState state)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.engine
Methods in org.apache.qpid.protonj2.engine that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
PerformativeEnvelope. getPayload()
ProtonBuffer
IncomingDelivery. readAll()
Returns the current read buffer without copying it effectively consuming all currently available bytes from this delivery.Methods in org.apache.qpid.protonj2.engine with parameters of type ProtonBuffer Modifier and Type Method Description default void
Engine. accept(ProtonBuffer input)
Provide data input for this Engine from some external source.void
EngineHandlerContext. fireRead(ProtonBuffer buffer)
Fires a read of ProtonBuffer events into the previous handler in theEnginePipeline
for further processing.EnginePipeline
EnginePipeline. fireRead(ProtonBuffer input)
Fires a read event consisting of the givenProtonBuffer
into the pipeline starting from the lastEngineHandler
in the pipeline and moving through each until the incoming work is fully processed.void
EngineHandlerContext. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)
Fires a write of ProtonBuffer events into the next handler in theEnginePipeline
for further processing.EnginePipeline
EnginePipeline. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)
Fires a write event consisting of the givenProtonBuffer
into the pipeline starting from the firstEngineHandler
in the pipeline and moving through each until the outgoing work is fully processed.default void
EngineHandler. handleRead(EngineHandlerContext context, ProtonBuffer buffer)
Handle the read of new incoming bytes from a remote sender.default void
EngineHandler. handleWrite(EngineHandlerContext context, ProtonBuffer buffer, java.lang.Runnable ioComplete)
Writes the given bytes to the output target or if no handler in the pipeline handles this calls the registered output handler of the parent Engine instance.Engine
Engine. ingest(ProtonBuffer input)
Provide data input for this Engine from some external source.IncomingDelivery
IncomingDelivery. readBytes(ProtonBuffer buffer)
Reads bytes from this delivery and writes them into the destination ProtonBuffer reducing the available bytes by the value of the number of bytes written to the target.OutgoingDelivery
OutgoingDelivery. streamBytes(ProtonBuffer buffer)
Write the given bytes as a portion of the payload of this delivery, additional bytes can be streamed until the stream complete flag is set to true on a call toOutgoingDelivery.streamBytes(ProtonBuffer, boolean)
or a call toOutgoingDelivery.writeBytes(ProtonBuffer)
is made.OutgoingDelivery
OutgoingDelivery. streamBytes(ProtonBuffer buffer, boolean complete)
Write the given bytes as a portion of the payload of this delivery, additional bytes can be streamed until the stream complete flag is set to true on a call toOutgoingDelivery.streamBytes(ProtonBuffer, boolean)
and the buffer contents on that send are fully written.E
AMQPPerformativeEnvelopePool. take(Performative body, int channel, ProtonBuffer payload)
Requests an envelope from the pool and if non is available creates one using the given builder this pool was created with.OutgoingDelivery
OutgoingDelivery. writeBytes(ProtonBuffer buffer)
Write the given bytes as the payload of this delivery, no additional writes can occur on this delivery if the write succeeds in sending all of the given bytes.Method parameters in org.apache.qpid.protonj2.engine with type arguments of type ProtonBuffer Modifier and Type Method Description default Engine
Engine. outputConsumer(java.util.function.Consumer<ProtonBuffer> consumer)
Sets aConsumer
instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).Engine
Engine. outputHandler(java.util.function.BiConsumer<ProtonBuffer,java.lang.Runnable> output)
Sets aBiConsumer
instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).default Engine
Engine. outputHandler(EventHandler<ProtonBuffer> output)
Sets a handler instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).Constructors in org.apache.qpid.protonj2.engine with parameters of type ProtonBuffer Constructor Description SASLEnvelope(SaslPerformative performative, ProtonBuffer payload)
Creates a new SASL envelope that wraps the given SASL performative. -
Uses of ProtonBuffer in org.apache.qpid.protonj2.engine.impl
Methods in org.apache.qpid.protonj2.engine.impl that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
ProtonIncomingDelivery. readAll()
ProtonBuffer
ProtonSequentialTagGenerator.ProtonNumericDeliveryTag. tagBuffer()
Methods in org.apache.qpid.protonj2.engine.impl with parameters of type ProtonBuffer Modifier and Type Method Description void
ProtonEngineHandlerContext. fireRead(ProtonBuffer buffer)
ProtonEnginePipeline
ProtonEnginePipeline. fireRead(ProtonBuffer input)
ProtonEnginePipelineProxy
ProtonEnginePipelineProxy. fireRead(ProtonBuffer input)
void
ProtonEngineHandlerContext. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)
ProtonEnginePipeline
ProtonEnginePipeline. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)
ProtonEnginePipelineProxy
ProtonEnginePipelineProxy. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)
void
ProtonConnection. handleAttach(Attach attach, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleAttach(Attach attach, ProtonBuffer payload, int channel, EngineHandlerContext context)
void
ProtonConnection. handleBegin(Begin begin, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleBegin(Begin begin, ProtonBuffer payload, int channel, EngineHandlerContext context)
void
ProtonConnection. handleClose(Close close, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleClose(Close close, ProtonBuffer payload, int channel, EngineHandlerContext context)
void
ProtonConnection. handleDetach(Detach detach, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleDetach(Detach detach, ProtonBuffer payload, int channel, EngineHandlerContext context)
void
ProtonConnection. handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, EngineHandlerContext context)
void
ProtonConnection. handleEnd(End end, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleEnd(End end, ProtonBuffer payload, int channel, EngineHandlerContext context)
void
ProtonConnection. handleFlow(Flow flow, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleFlow(Flow flow, ProtonBuffer payload, int channel, EngineHandlerContext context)
void
ProtonConnection. handleOpen(Open open, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleOpen(Open open, ProtonBuffer payload, int channel, EngineHandlerContext context)
void
ProtonFrameDecodingHandler. handleRead(EngineHandlerContext context, ProtonBuffer buffer)
protected abstract ProtonIncomingDelivery
ProtonLink. handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)
protected ProtonIncomingDelivery
ProtonReceiver. handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)
protected ProtonIncomingDelivery
ProtonSender. handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)
void
ProtonConnection. handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, ProtonEngine context)
void
ProtonPerformativeHandler. handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, EngineHandlerContext context)
ProtonEngine
ProtonEngine. ingest(ProtonBuffer input)
ProtonIncomingDelivery
ProtonIncomingDelivery. readBytes(ProtonBuffer buffer)
OutgoingDelivery
ProtonOutgoingDelivery. streamBytes(ProtonBuffer buffer)
OutgoingDelivery
ProtonOutgoingDelivery. streamBytes(ProtonBuffer buffer, boolean complete)
OutgoingDelivery
ProtonOutgoingDelivery. writeBytes(ProtonBuffer buffer)
void
ProtonSequentialTagGenerator.ProtonNumericDeliveryTag. writeTo(ProtonBuffer buffer)
Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type ProtonBuffer Modifier and Type Method Description ProtonEngine
ProtonEngine. outputHandler(java.util.function.BiConsumer<ProtonBuffer,java.lang.Runnable> handler)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.engine.sasl
Methods in org.apache.qpid.protonj2.engine.sasl with parameters of type ProtonBuffer Modifier and Type Method Description void
SaslClientListener. handleSaslChallenge(SaslClientContext context, ProtonBuffer challenge)
Called when a SASL challenge frame has arrived and its effect applied, indicating the challenge sent by the 'server' peer.void
SaslServerListener. handleSaslInit(SaslServerContext context, Symbol mechanism, ProtonBuffer initResponse)
Called when a SASL init frame has arrived from the client indicating the chosen SASL mechanism and the initial response data if any.void
SaslClientListener. handleSaslOutcome(SaslClientContext context, SaslOutcome outcome, ProtonBuffer additional)
Called when a SASL outcome frame has arrived and its effect applied, indicating the outcome and any success additional data sent by the 'server' peer.void
SaslServerListener. handleSaslResponse(SaslServerContext context, ProtonBuffer response)
Called when a SASL response frame has arrived from the client.SaslServerContext
SaslServerContext. sendChallenge(ProtonBuffer challenge)
Sends the SASL challenge defined by the SASL mechanism that is in use during this SASL negotiation.SaslClientContext
SaslClientContext. sendChosenMechanism(Symbol mechanism, java.lang.String host, ProtonBuffer initialResponse)
Sends a response to the SASL server indicating the chosen mechanism for this client and the host name that this client is identifying itself as.SaslServerContext
SaslServerContext. sendOutcome(SaslOutcome outcome, ProtonBuffer additional)
Sends a response to a server side challenge that comprises the challenge / response exchange for the chosen SASL mechanism.SaslClientContext
SaslClientContext. sendResponse(ProtonBuffer response)
Sends a response to a server side challenge that comprises the challenge / response exchange for the chosen SASL mechanism. -
Uses of ProtonBuffer in org.apache.qpid.protonj2.engine.sasl.client
Fields in org.apache.qpid.protonj2.engine.sasl.client declared as ProtonBuffer Modifier and Type Field Description protected static ProtonBuffer
AbstractMechanism. EMPTY
Methods in org.apache.qpid.protonj2.engine.sasl.client with parameters of type ProtonBuffer Modifier and Type Method Description ProtonBuffer
AbstractMechanism. getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
ProtonBuffer
CramMD5Mechanism. getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
ProtonBuffer
Mechanism. getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
Create a response based on a given challenge from the remote peer.ProtonBuffer
XOauth2Mechanism. getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
void
SaslAuthenticator. handleSaslChallenge(SaslClientContext context, ProtonBuffer challenge)
void
SaslAuthenticator. handleSaslOutcome(SaslClientContext context, SaslOutcome outcome, ProtonBuffer additional)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.engine.util
Methods in org.apache.qpid.protonj2.engine.util with parameters of type ProtonBuffer Modifier and Type Method Description static java.lang.String
StringUtils. toQuotedString(ProtonBuffer buffer)
Converts the ProtonBuffer to a quoted string using a default max length before truncation value and appends a truncation indication if the string required truncation.static java.lang.String
StringUtils. toQuotedString(ProtonBuffer buffer, boolean appendIfTruncated)
Converts the ProtonBuffer to a quoted string using a default max length before truncation value.static java.lang.String
StringUtils. toQuotedString(ProtonBuffer buffer, int stringLength, boolean appendIfTruncated)
Converts the ProtonBuffer to a quoted string. -
Uses of ProtonBuffer in org.apache.qpid.protonj2.types
Methods in org.apache.qpid.protonj2.types that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
Binary. asProtonBuffer()
ProtonBuffer
DeliveryTag.ProtonDeliveryTag. tagBuffer()
ProtonBuffer
DeliveryTag. tagBuffer()
Returns a view of thisDeliveryTag
object as aProtonBuffer
.Methods in org.apache.qpid.protonj2.types with parameters of type ProtonBuffer Modifier and Type Method Description static Symbol
Symbol. getSymbol(ProtonBuffer symbolBytes)
static Symbol
Symbol. getSymbol(ProtonBuffer symbolBuffer, boolean copyOnCreate)
void
DeliveryTag.ProtonDeliveryTag. writeTo(ProtonBuffer buffer)
void
DeliveryTag. writeTo(ProtonBuffer buffer)
Writes the tag as a sequence of bytes into the given buffer in the manner most efficient for the underlyingDeliveryTag
implementation.void
Symbol. writeTo(ProtonBuffer target)
Writes the internalSymbol
bytes to the providedProtonBuffer
.Constructors in org.apache.qpid.protonj2.types with parameters of type ProtonBuffer Constructor Description Binary(ProtonBuffer buffer)
ProtonDeliveryTag(ProtonBuffer tagBytes)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.types.messaging
Constructors in org.apache.qpid.protonj2.types.messaging with parameters of type ProtonBuffer Constructor Description Data(ProtonBuffer value)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.types.security
Methods in org.apache.qpid.protonj2.types.security that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
SaslOutcome. getAdditionalData()
ProtonBuffer
SaslChallenge. getChallenge()
ProtonBuffer
SaslInit. getInitialResponse()
ProtonBuffer
SaslResponse. getResponse()
Methods in org.apache.qpid.protonj2.types.security with parameters of type ProtonBuffer Modifier and Type Method Description SaslOutcome
SaslOutcome. setAdditionalData(ProtonBuffer additionalData)
SaslChallenge
SaslChallenge. setChallenge(ProtonBuffer challenge)
SaslInit
SaslInit. setInitialResponse(ProtonBuffer initialResponse)
SaslResponse
SaslResponse. setResponse(ProtonBuffer response)
-
Uses of ProtonBuffer in org.apache.qpid.protonj2.types.transport
Methods in org.apache.qpid.protonj2.types.transport that return ProtonBuffer Modifier and Type Method Description ProtonBuffer
AMQPHeader. getBuffer()
Methods in org.apache.qpid.protonj2.types.transport with parameters of type ProtonBuffer Modifier and Type Method Description default void
Performative.PerformativeHandler. handleAttach(Attach attach, ProtonBuffer payload, int channel, E context)
default void
Performative.PerformativeHandler. handleBegin(Begin begin, ProtonBuffer payload, int channel, E context)
default void
Performative.PerformativeHandler. handleClose(Close close, ProtonBuffer payload, int channel, E context)
default void
Performative.PerformativeHandler. handleDetach(Detach detach, ProtonBuffer payload, int channel, E context)
default void
Performative.PerformativeHandler. handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, E context)
default void
Performative.PerformativeHandler. handleEnd(End end, ProtonBuffer payload, int channel, E context)
default void
Performative.PerformativeHandler. handleFlow(Flow flow, ProtonBuffer payload, int channel, E context)
default void
Performative.PerformativeHandler. handleOpen(Open open, ProtonBuffer payload, int channel, E context)
default void
Performative.PerformativeHandler. handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, E context)
<E> void
Attach. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
Begin. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
Close. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
Detach. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
Disposition. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
End. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
Flow. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
Open. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
Performative. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void
Transfer. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
Transfer
Transfer. setDeliveryTag(ProtonBuffer tagBytes)
Constructors in org.apache.qpid.protonj2.types.transport with parameters of type ProtonBuffer Constructor Description AMQPHeader(ProtonBuffer buffer)
AMQPHeader(ProtonBuffer buffer, boolean validate)
-