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 classProtonAbstractBufferBase class used to hold the common implementation details for Proton buffer implementations.classProtonByteBufferImplementation of the ProtonBuffer interface that uses an array backing the buffer that is dynamically resized as bytes are written.classProtonCompositeBufferA composite of 1 or more ProtonBuffer instances used when aggregating buffer views.classProtonDuplicatedBufferA duplicated buffer wrapper for buffers known to beProtonAbstractBufferinstances.classProtonNettyByteBufferWrapper class for Netty ByteBuf instancesclassProtonNioByteBufferProtonBuffer wrapper around a NIO ByteBuffer instance.classProtonSlicedBufferPresents a sliced view of aProtonAbstractBuffer.Methods in org.apache.qpid.protonj2.buffer that return ProtonBuffer Modifier and Type Method Description ProtonBufferProtonBufferAllocator. allocate()Create a new ProtonBuffer instance with default initial capacity.ProtonBufferProtonBufferAllocator. 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.ProtonBufferProtonBufferAllocator. 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.ProtonBufferProtonBuffer. capacity(int newCapacity)Adjusts the capacity of this buffer.ProtonBufferProtonByteBuffer. capacity(int newCapacity)ProtonBufferProtonCompositeBuffer. capacity(int newCapacity)ProtonBufferProtonDuplicatedBuffer. capacity(int newCapacity)ProtonBufferProtonNettyByteBuffer. capacity(int newCapacity)ProtonBufferProtonNioByteBuffer. capacity(int newCapacity)ProtonBufferProtonSlicedBuffer. capacity(int newCapacity)ProtonBufferProtonAbstractBuffer. clear()ProtonBufferProtonBuffer. 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.ProtonBufferProtonNettyByteBuffer. clear()ProtonBufferProtonAbstractBuffer. copy()abstract ProtonBufferProtonAbstractBuffer. copy(int index, int length)ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. copy(int index, int length)Returns a copy of this buffer's sub-region.ProtonBufferProtonByteBuffer. copy(int index, int length)ProtonBufferProtonCompositeBuffer. copy(int index, int length)ProtonBufferProtonDuplicatedBuffer. copy(int index, int length)ProtonBufferProtonNettyByteBuffer. copy()ProtonBufferProtonNettyByteBuffer. copy(int index, int length)ProtonBufferProtonNioByteBuffer. copy(int index, int length)ProtonBufferProtonSlicedBuffer. copy(int index, int length)ProtonBufferProtonAbstractBuffer. duplicate()ProtonBufferProtonBuffer. duplicate()Create a duplicate of this ProtonBuffer instance that shares the same backing data store and but maintains separate position index values.ProtonBufferProtonCompositeBuffer. duplicate()ProtonBufferProtonDuplicatedBuffer. duplicate()ProtonBufferProtonNettyByteBuffer. duplicate()ProtonBufferProtonSlicedBuffer. duplicate()ProtonBufferProtonAbstractBuffer. ensureWritable(int minWritableBytes)ProtonBufferProtonBuffer. 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.ProtonBufferProtonNettyByteBuffer. ensureWritable(int minWritableBytes)ProtonBufferProtonAbstractBuffer. getBytes(int index, byte[] target)ProtonBufferProtonAbstractBuffer. getBytes(int index, ProtonBuffer target)ProtonBufferProtonAbstractBuffer. getBytes(int index, ProtonBuffer target, int length)ProtonBufferProtonBuffer. getBytes(int index, byte[] destination)Transfers this buffer's data to the specified destination starting at the specified absoluteindex.ProtonBufferProtonBuffer. getBytes(int index, byte[] destination, int offset, int length)Transfers this buffer's data to the specified destination starting at the specified absoluteindex.ProtonBufferProtonBuffer. getBytes(int index, java.nio.ByteBuffer destination)Transfers this buffer's data to the specified destination starting at the specified absoluteindexuntil the destination's position reaches its limit.ProtonBufferProtonBuffer. getBytes(int index, ProtonBuffer destination)Transfers this buffer's data to the specified destination starting at the specified absoluteindexuntil the destination becomes non-writable.ProtonBufferProtonBuffer. getBytes(int index, ProtonBuffer destination, int length)Transfers this buffer's data to the specified destination starting at the specified absoluteindex.ProtonBufferProtonBuffer. getBytes(int index, ProtonBuffer destination, int offset, int length)Transfers this buffer's data to the specified destination starting at the specified absoluteindex.ProtonBufferProtonByteBuffer. getBytes(int index, byte[] destination, int destinationIndex, int length)ProtonBufferProtonByteBuffer. getBytes(int index, java.nio.ByteBuffer destination)ProtonBufferProtonByteBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)ProtonBufferProtonCompositeBuffer. getBytes(int index, byte[] destination, int offset, int length)ProtonBufferProtonCompositeBuffer. getBytes(int index, java.nio.ByteBuffer destination)ProtonBufferProtonCompositeBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)ProtonBufferProtonDuplicatedBuffer. getBytes(int index, byte[] destination, int offset, int length)ProtonBufferProtonDuplicatedBuffer. getBytes(int index, java.nio.ByteBuffer destination)ProtonBufferProtonDuplicatedBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)ProtonBufferProtonNettyByteBuffer. getBytes(int index, byte[] destination)ProtonBufferProtonNettyByteBuffer. getBytes(int index, byte[] destination, int offset, int length)ProtonBufferProtonNettyByteBuffer. getBytes(int index, java.nio.ByteBuffer destination)ProtonBufferProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination)ProtonBufferProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination, int length)ProtonBufferProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination, int offset, int length)ProtonBufferProtonNioByteBuffer. getBytes(int index, byte[] destination, int offset, int length)ProtonBufferProtonNioByteBuffer. getBytes(int index, java.nio.ByteBuffer destination)ProtonBufferProtonNioByteBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)ProtonBufferProtonSlicedBuffer. getBytes(int index, byte[] dst)ProtonBufferProtonSlicedBuffer. getBytes(int index, byte[] dst, int offset, int length)ProtonBufferProtonSlicedBuffer. getBytes(int index, java.nio.ByteBuffer destination)ProtonBufferProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst)ProtonBufferProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst, int length)ProtonBufferProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst, int dstIndex, int length)ProtonBufferProtonAbstractBuffer. markReadIndex()ProtonBufferProtonBuffer. markReadIndex()Marks the current read index so that it can later be restored by a call toresetReadIndex(), the initial mark value is 0.ProtonBufferProtonNettyByteBuffer. markReadIndex()ProtonBufferProtonAbstractBuffer. markWriteIndex()ProtonBufferProtonBuffer. markWriteIndex()Marks the current write index so that it can later be restored by a call toresetWriteIndex(), the initial mark value is 0.ProtonBufferProtonNettyByteBuffer. markWriteIndex()ProtonBufferProtonBufferAllocator. 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.ProtonBufferProtonBufferAllocator. 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.ProtonBufferProtonByteBufferAllocator. outputBuffer(int initialCapacity)ProtonBufferProtonByteBufferAllocator. outputBuffer(int initialCapacity, int maximumCapacity)ProtonBufferProtonNettyByteBufferAllocator. outputBuffer(int initialCapacity)ProtonBufferProtonNettyByteBufferAllocator. outputBuffer(int initialCapacity, int maximumCapacity)ProtonBufferProtonAbstractBuffer. readBytes(byte[] target)ProtonBufferProtonAbstractBuffer. readBytes(byte[] target, int length)ProtonBufferProtonAbstractBuffer. readBytes(byte[] target, int offset, int length)ProtonBufferProtonAbstractBuffer. readBytes(java.nio.ByteBuffer dst)ProtonBufferProtonAbstractBuffer. readBytes(ProtonBuffer target)ProtonBufferProtonAbstractBuffer. readBytes(ProtonBuffer target, int length)ProtonBufferProtonAbstractBuffer. readBytes(ProtonBuffer target, int offset, int length)ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. readBytes(java.nio.ByteBuffer destination)Transfers this buffer's data to the specified destination starting at the currentreadIndexuntil the destination's position reaches its limit, and increases thereadIndexby the number of the transferred bytes.ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. readBytes(ProtonBuffer target, int offset, int length)Transfers this buffer's data to the specified destination starting at the currentreadIndexand increases thereadIndexby the number of the transferred bytes (=length).ProtonBufferProtonNettyByteBuffer. readBytes(byte[] destination)ProtonBufferProtonNettyByteBuffer. readBytes(byte[] destination, int length)ProtonBufferProtonNettyByteBuffer. readBytes(byte[] destination, int offset, int length)ProtonBufferProtonNettyByteBuffer. readBytes(java.nio.ByteBuffer destination)ProtonBufferProtonNettyByteBuffer. readBytes(ProtonBuffer destination)ProtonBufferProtonNettyByteBuffer. readBytes(ProtonBuffer destination, int length)ProtonBufferProtonNettyByteBuffer. readBytes(ProtonBuffer destination, int offset, int length)ProtonBufferProtonAbstractBuffer. resetReadIndex()ProtonBufferProtonBuffer. resetReadIndex()Resets the current read index to the previously marked value.ProtonBufferProtonNettyByteBuffer. resetReadIndex()ProtonBufferProtonAbstractBuffer. resetWriteIndex()ProtonBufferProtonBuffer. resetWriteIndex()Resets the current write index to the previously marked value.ProtonBufferProtonNettyByteBuffer. resetWriteIndex()ProtonBufferProtonAbstractBuffer. setBoolean(int index, boolean value)ProtonBufferProtonBuffer. setBoolean(int index, boolean value)Sets the boolean value at the given write index in this buffer's backing data store.ProtonBufferProtonNettyByteBuffer. setBoolean(int index, boolean value)ProtonBufferProtonSlicedBuffer. setBoolean(int index, boolean value)ProtonBufferProtonBuffer. setByte(int index, int value)Sets the byte value at the given write index in this buffer's backing data store.ProtonBufferProtonByteBuffer. setByte(int index, int value)ProtonBufferProtonCompositeBuffer. setByte(int index, int value)ProtonBufferProtonDuplicatedBuffer. setByte(int index, int value)ProtonBufferProtonNettyByteBuffer. setByte(int index, int value)ProtonBufferProtonNioByteBuffer. setByte(int index, int value)ProtonBufferProtonSlicedBuffer. setByte(int index, int value)ProtonBufferProtonAbstractBuffer. setBytes(int index, byte[] src)ProtonBufferProtonAbstractBuffer. setBytes(int index, ProtonBuffer source)ProtonBufferProtonAbstractBuffer. setBytes(int index, ProtonBuffer source, int length)ProtonBufferProtonBuffer. setBytes(int index, byte[] source)Transfers the specified source array's data to this buffer starting at the specified absoluteindex.ProtonBufferProtonBuffer. setBytes(int index, byte[] source, int offset, int length)Transfers the specified source array's data to this buffer starting at the specified absoluteindex.ProtonBufferProtonBuffer. setBytes(int index, java.nio.ByteBuffer source)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindexuntil the source buffer's position reaches its limit.ProtonBufferProtonBuffer. setBytes(int index, ProtonBuffer source)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindexuntil the source buffer becomes unreadable.ProtonBufferProtonBuffer. setBytes(int index, ProtonBuffer source, int length)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex.ProtonBufferProtonBuffer. setBytes(int index, ProtonBuffer source, int offset, int length)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex.ProtonBufferProtonByteBuffer. setBytes(int index, byte[] source, int sourceIndex, int length)ProtonBufferProtonByteBuffer. setBytes(int index, java.nio.ByteBuffer src)ProtonBufferProtonByteBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonCompositeBuffer. setBytes(int index, byte[] source, int sourceIndex, int length)ProtonBufferProtonCompositeBuffer. setBytes(int index, java.nio.ByteBuffer source)ProtonBufferProtonCompositeBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonDuplicatedBuffer. setBytes(int index, byte[] source, int sourceIndex, int length)ProtonBufferProtonDuplicatedBuffer. setBytes(int index, java.nio.ByteBuffer source)ProtonBufferProtonDuplicatedBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonNettyByteBuffer. setBytes(int index, byte[] value)ProtonBufferProtonNettyByteBuffer. setBytes(int index, byte[] value, int offset, int length)ProtonBufferProtonNettyByteBuffer. setBytes(int index, java.nio.ByteBuffer value)ProtonBufferProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value)ProtonBufferProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value, int length)ProtonBufferProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value, int offset, int length)ProtonBufferProtonNioByteBuffer. setBytes(int index, byte[] source, int sourceIndex, int length)ProtonBufferProtonNioByteBuffer. setBytes(int index, java.nio.ByteBuffer source)ProtonBufferProtonNioByteBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonSlicedBuffer. setBytes(int index, byte[] source)ProtonBufferProtonSlicedBuffer. setBytes(int index, byte[] src, int srcIndex, int length)ProtonBufferProtonSlicedBuffer. setBytes(int index, java.nio.ByteBuffer source)ProtonBufferProtonSlicedBuffer. setBytes(int index, ProtonBuffer source)ProtonBufferProtonSlicedBuffer. setBytes(int index, ProtonBuffer source, int length)ProtonBufferProtonSlicedBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonAbstractBuffer. setChar(int index, int value)ProtonBufferProtonBuffer. setChar(int index, int value)Sets the char value at the given write index in this buffer's backing data store.ProtonBufferProtonNettyByteBuffer. setChar(int index, int value)ProtonBufferProtonSlicedBuffer. setChar(int index, int value)ProtonBufferProtonAbstractBuffer. setDouble(int index, double value)ProtonBufferProtonBuffer. setDouble(int index, double value)Sets the double value at the given write index in this buffer's backing data store.ProtonBufferProtonNettyByteBuffer. setDouble(int index, double value)ProtonBufferProtonSlicedBuffer. setDouble(int index, double value)ProtonBufferProtonAbstractBuffer. setFloat(int index, float value)ProtonBufferProtonBuffer. setFloat(int index, float value)Sets the float value at the given write index in this buffer's backing data store.ProtonBufferProtonNettyByteBuffer. setFloat(int index, float value)ProtonBufferProtonSlicedBuffer. setFloat(int index, float value)ProtonBufferProtonAbstractBuffer. setIndex(int readIndex, int writeIndex)ProtonBufferProtonBuffer. setIndex(int readIndex, int writeIndex)Used to set the read index and the write index in one call.ProtonBufferProtonNettyByteBuffer. setIndex(int readIndex, int writeIndex)ProtonBufferProtonBuffer. setInt(int index, int value)Sets the int value at the given write index in this buffer's backing data store.ProtonBufferProtonByteBuffer. setInt(int index, int value)ProtonBufferProtonCompositeBuffer. setInt(int index, int value)ProtonBufferProtonDuplicatedBuffer. setInt(int index, int value)ProtonBufferProtonNettyByteBuffer. setInt(int index, int value)ProtonBufferProtonNioByteBuffer. setInt(int index, int value)ProtonBufferProtonSlicedBuffer. setInt(int index, int value)ProtonBufferProtonBuffer. setLong(int index, long value)Sets the long value at the given write index in this buffer's backing data store.ProtonBufferProtonByteBuffer. setLong(int index, long value)ProtonBufferProtonCompositeBuffer. setLong(int index, long value)ProtonBufferProtonDuplicatedBuffer. setLong(int index, long value)ProtonBufferProtonNettyByteBuffer. setLong(int index, long value)ProtonBufferProtonNioByteBuffer. setLong(int index, long value)ProtonBufferProtonSlicedBuffer. setLong(int index, long value)ProtonBufferProtonAbstractBuffer. setReadIndex(int value)ProtonBufferProtonBuffer. setReadIndex(int value)Sets the read index for this buffer.ProtonBufferProtonNettyByteBuffer. setReadIndex(int index)ProtonBufferProtonBuffer. setShort(int index, int value)Sets the short value at the given write index in this buffer's backing data store.ProtonBufferProtonByteBuffer. setShort(int index, int value)ProtonBufferProtonCompositeBuffer. setShort(int index, int value)ProtonBufferProtonDuplicatedBuffer. setShort(int index, int value)ProtonBufferProtonNettyByteBuffer. setShort(int index, int value)ProtonBufferProtonNioByteBuffer. setShort(int index, int value)ProtonBufferProtonSlicedBuffer. setShort(int index, int value)ProtonBufferProtonAbstractBuffer. setWriteIndex(int value)ProtonBufferProtonBuffer. setWriteIndex(int value)Sets the write index for this buffer.ProtonBufferProtonNettyByteBuffer. setWriteIndex(int index)ProtonBufferProtonAbstractBuffer. skipBytes(int length)ProtonBufferProtonBuffer. skipBytes(int length)Increases the currentreadIndexof this buffer by the specifiedlength.ProtonBufferProtonNettyByteBuffer. skipBytes(int skippedBytes)ProtonBufferProtonAbstractBuffer. slice()ProtonBufferProtonAbstractBuffer. slice(int index, int length)ProtonBufferProtonBuffer. slice()Create a new ProtonBuffer whose contents are a subsequence of the contents of thisProtonBuffer.ProtonBufferProtonBuffer. slice(int index, int length)Create a new ProtonBuffer whose contents are a subsequence of the contents of thisProtonBuffer.ProtonBufferProtonDuplicatedBuffer. slice(int index, int length)ProtonBufferProtonNettyByteBuffer. slice()ProtonBufferProtonNettyByteBuffer. slice(int index, int length)ProtonBufferProtonSlicedBuffer. slice(int index, int length)ProtonBufferProtonBufferAllocator. wrap(byte[] array)Create a new ProtonBuffer that wraps the given byte array.ProtonBufferProtonBufferAllocator. 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.ProtonBufferProtonBufferAllocator. wrap(java.nio.ByteBuffer buffer)Create a new ProtonBuffer that wraps the given ByteBuffer.ProtonBufferProtonByteBufferAllocator. wrap(byte[] array)ProtonBufferProtonByteBufferAllocator. wrap(byte[] array, int offset, int length)ProtonBufferProtonByteBufferAllocator. wrap(java.nio.ByteBuffer buffer)ProtonBufferProtonNettyByteBufferAllocator. wrap(byte[] array)ProtonBufferProtonNettyByteBufferAllocator. wrap(byte[] array, int offset, int length)ProtonBufferProtonNettyByteBufferAllocator. wrap(java.nio.ByteBuffer buffer)ProtonBufferProtonAbstractBuffer. writeBoolean(boolean value)ProtonBufferProtonBuffer. writeBoolean(boolean value)Writes a single boolean to the buffer and advances the write index by one.ProtonBufferProtonNettyByteBuffer. writeBoolean(boolean value)ProtonBufferProtonAbstractBuffer. writeByte(int value)ProtonBufferProtonBuffer. writeByte(int value)Writes a single byte to the buffer and advances the write index by one.ProtonBufferProtonNettyByteBuffer. writeByte(int value)ProtonBufferProtonAbstractBuffer. writeBytes(byte[] source)ProtonBufferProtonAbstractBuffer. writeBytes(byte[] source, int length)ProtonBufferProtonAbstractBuffer. writeBytes(byte[] source, int offset, int length)ProtonBufferProtonAbstractBuffer. writeBytes(java.nio.ByteBuffer source)ProtonBufferProtonAbstractBuffer. writeBytes(ProtonBuffer source)ProtonBufferProtonAbstractBuffer. writeBytes(ProtonBuffer source, int length)ProtonBufferProtonAbstractBuffer. writeBytes(ProtonBuffer source, int offset, int length)ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. writeBytes(java.nio.ByteBuffer source)Transfers the specified source buffer's data to this buffer starting at the currentwriteIndexuntil the source buffer's position reaches its limit, and increases thewriteIndexby the number of the transferred bytes.ProtonBufferProtonBuffer. writeBytes(ProtonBuffer source)Transfers the specified source buffer's data to this buffer starting at the currentwriteIndexuntil the source buffer becomes unreadable, and increases thewriteIndexby the number of the transferred bytes.ProtonBufferProtonBuffer. writeBytes(ProtonBuffer source, int length)Transfers the specified source buffer's data to this buffer starting at the currentwriteIndexand increases thewriteIndexby the number of the transferred bytes (=length).ProtonBufferProtonBuffer. writeBytes(ProtonBuffer source, int offset, int length)Transfers the specified source buffer's data to this buffer starting at the currentwriteIndexand increases thewriteIndexby the number of the transferred bytes (=length).ProtonBufferProtonNettyByteBuffer. writeBytes(byte[] value)ProtonBufferProtonNettyByteBuffer. writeBytes(byte[] value, int length)ProtonBufferProtonNettyByteBuffer. writeBytes(byte[] array, int offset, int length)ProtonBufferProtonNettyByteBuffer. writeBytes(java.nio.ByteBuffer value)ProtonBufferProtonNettyByteBuffer. writeBytes(ProtonBuffer value)ProtonBufferProtonNettyByteBuffer. writeBytes(ProtonBuffer value, int length)ProtonBufferProtonNettyByteBuffer. writeBytes(ProtonBuffer value, int offset, int length)ProtonBufferProtonAbstractBuffer. writeDouble(double value)ProtonBufferProtonBuffer. writeDouble(double value)Writes a single double to the buffer and advances the write index by eight.ProtonBufferProtonNettyByteBuffer. writeDouble(double value)ProtonBufferProtonAbstractBuffer. writeFloat(float value)ProtonBufferProtonBuffer. writeFloat(float value)Writes a single float to the buffer and advances the write index by four.ProtonBufferProtonNettyByteBuffer. writeFloat(float value)ProtonBufferProtonAbstractBuffer. writeInt(int value)ProtonBufferProtonBuffer. writeInt(int value)Writes a single integer to the buffer and advances the write index by four.ProtonBufferProtonNettyByteBuffer. writeInt(int value)ProtonBufferProtonAbstractBuffer. writeLong(long value)ProtonBufferProtonBuffer. writeLong(long value)Writes a single long to the buffer and advances the write index by eight.ProtonBufferProtonNettyByteBuffer. writeLong(long value)ProtonBufferProtonAbstractBuffer. writeShort(short value)ProtonBufferProtonBuffer. writeShort(short value)Writes a single short to the buffer and advances the write index by two.ProtonBufferProtonNettyByteBuffer. writeShort(short value)Methods in org.apache.qpid.protonj2.buffer with parameters of type ProtonBuffer Modifier and Type Method Description ProtonCompositeBufferProtonCompositeBuffer. append(ProtonBuffer buffer)Appends the givenProtonBufferto the end of the buffer segments that comprise this compositeProtonBufferinstance.intProtonAbstractBuffer. compareTo(ProtonBuffer other)intProtonBuffer. compareTo(ProtonBuffer buffer)Compares the remaining content of the current buffer with the remaining content of the given buffer, which must not be null.intProtonNettyByteBuffer. compareTo(ProtonBuffer other)ProtonBufferProtonAbstractBuffer. getBytes(int index, ProtonBuffer target)ProtonBufferProtonAbstractBuffer. getBytes(int index, ProtonBuffer target, int length)ProtonBufferProtonBuffer. getBytes(int index, ProtonBuffer destination)Transfers this buffer's data to the specified destination starting at the specified absoluteindexuntil the destination becomes non-writable.ProtonBufferProtonBuffer. getBytes(int index, ProtonBuffer destination, int length)Transfers this buffer's data to the specified destination starting at the specified absoluteindex.ProtonBufferProtonBuffer. getBytes(int index, ProtonBuffer destination, int offset, int length)Transfers this buffer's data to the specified destination starting at the specified absoluteindex.ProtonBufferProtonByteBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)ProtonBufferProtonCompositeBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)ProtonBufferProtonDuplicatedBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)ProtonBufferProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination)ProtonBufferProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination, int length)ProtonBufferProtonNettyByteBuffer. getBytes(int index, ProtonBuffer destination, int offset, int length)ProtonBufferProtonNioByteBuffer. getBytes(int index, ProtonBuffer destination, int destinationIndex, int length)ProtonBufferProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst)ProtonBufferProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst, int length)ProtonBufferProtonSlicedBuffer. getBytes(int index, ProtonBuffer dst, int dstIndex, int length)ProtonBufferProtonAbstractBuffer. readBytes(ProtonBuffer target)ProtonBufferProtonAbstractBuffer. readBytes(ProtonBuffer target, int length)ProtonBufferProtonAbstractBuffer. readBytes(ProtonBuffer target, int offset, int length)ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. 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.ProtonBufferProtonBuffer. readBytes(ProtonBuffer target, int offset, int length)Transfers this buffer's data to the specified destination starting at the currentreadIndexand increases thereadIndexby the number of the transferred bytes (=length).ProtonBufferProtonNettyByteBuffer. readBytes(ProtonBuffer destination)ProtonBufferProtonNettyByteBuffer. readBytes(ProtonBuffer destination, int length)ProtonBufferProtonNettyByteBuffer. readBytes(ProtonBuffer destination, int offset, int length)ProtonBufferProtonAbstractBuffer. setBytes(int index, ProtonBuffer source)ProtonBufferProtonAbstractBuffer. setBytes(int index, ProtonBuffer source, int length)ProtonBufferProtonBuffer. setBytes(int index, ProtonBuffer source)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindexuntil the source buffer becomes unreadable.ProtonBufferProtonBuffer. setBytes(int index, ProtonBuffer source, int length)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex.ProtonBufferProtonBuffer. setBytes(int index, ProtonBuffer source, int offset, int length)Transfers the specified source buffer's data to this buffer starting at the specified absoluteindex.ProtonBufferProtonByteBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonCompositeBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonDuplicatedBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value)ProtonBufferProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value, int length)ProtonBufferProtonNettyByteBuffer. setBytes(int index, ProtonBuffer value, int offset, int length)ProtonBufferProtonNioByteBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonSlicedBuffer. setBytes(int index, ProtonBuffer source)ProtonBufferProtonSlicedBuffer. setBytes(int index, ProtonBuffer source, int length)ProtonBufferProtonSlicedBuffer. setBytes(int index, ProtonBuffer source, int sourceIndex, int length)ProtonBufferProtonAbstractBuffer. writeBytes(ProtonBuffer source)ProtonBufferProtonAbstractBuffer. writeBytes(ProtonBuffer source, int length)ProtonBufferProtonAbstractBuffer. writeBytes(ProtonBuffer source, int offset, int length)ProtonBufferProtonBuffer. writeBytes(ProtonBuffer source)Transfers the specified source buffer's data to this buffer starting at the currentwriteIndexuntil the source buffer becomes unreadable, and increases thewriteIndexby the number of the transferred bytes.ProtonBufferProtonBuffer. writeBytes(ProtonBuffer source, int length)Transfers the specified source buffer's data to this buffer starting at the currentwriteIndexand increases thewriteIndexby the number of the transferred bytes (=length).ProtonBufferProtonBuffer. writeBytes(ProtonBuffer source, int offset, int length)Transfers the specified source buffer's data to this buffer starting at the currentwriteIndexand increases thewriteIndexby the number of the transferred bytes (=length).ProtonBufferProtonNettyByteBuffer. writeBytes(ProtonBuffer value)ProtonBufferProtonNettyByteBuffer. writeBytes(ProtonBuffer value, int length)ProtonBufferProtonNettyByteBuffer. 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 ProtonCompositeBufferProtonCompositeBuffer. foreachBuffer(java.util.function.Consumer<ProtonBuffer> consumer)For each of the buffers contained in thisProtonCompositeBufferinstance 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.ProtonCompositeBufferProtonCompositeBuffer. foreachInternalBuffer(java.util.function.Consumer<ProtonBuffer> consumer)For each of the buffers contained in thisProtonCompositeBufferinstance the given consumer will be invoked with theProtonBufferthat backs this composite instance.Constructors in org.apache.qpid.protonj2.buffer with parameters of type ProtonBuffer Constructor Description ProtonBufferInputStream(ProtonBuffer buffer)Creates a newInputStreaminstance that wraps the givenProtonBufferProtonBufferOutputStream(ProtonBuffer buffer)Create a newOutputStreamwhich 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 ProtonBufferAdvancedMessage. encode(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)Encodes theAdvancedMessagefor 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 ProtonBufferClientMessage. encode(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)ProtonBufferClientStreamReceiverMessage. encode(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)static ProtonBufferClientMessageSupport. encodeMessage(AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)static ProtonBufferClientMessageSupport. encodeMessage(Encoder encoder, ProtonBufferAllocator allocator, AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)static ProtonBufferClientMessageSupport. encodeMessage(Encoder encoder, EncoderState encoderState, ProtonBufferAllocator allocator, AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)static ProtonBufferClientMessageSupport. encodeSection(Section<?> section, ProtonBuffer buffer)ProtonBufferClientOutgoingEnvelope. 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 ProtonBufferClientMessageSupport. 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.ByteBufTcpTransport. toOutputBuffer(ProtonBuffer output)voidTransportListener. transportRead(ProtonBuffer incoming)Called when new incoming data has become available for processing by theTransportuser.TcpTransportTcpTransport. write(ProtonBuffer output)TcpTransportTcpTransport. write(ProtonBuffer output, java.lang.Runnable onComplete)TransportTransport. write(ProtonBuffer output)Writes a chunk of data over the Transport connection without performing an explicit flush on the transport.TransportTransport. write(ProtonBuffer output, java.lang.Runnable ioComplete)Writes a chunk of data over the Transport connection without performing an explicit flush on the transport.WebSocketTransportWebSocketTransport. write(ProtonBuffer output, java.lang.Runnable onComplete)TcpTransportTcpTransport. writeAndFlush(ProtonBuffer output)TcpTransportTcpTransport. writeAndFlush(ProtonBuffer output, java.lang.Runnable onComplete)TransportTransport. writeAndFlush(ProtonBuffer output)Writes a chunk of data over the Transport connection and requests a flush of all pending queued write operationsTransportTransport. 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 operationsWebSocketTransportWebSocketTransport. 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 ProtonBufferEncoderState. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)Encodes the given sequence of characters in UTF8 to the given buffer.ProtonBufferDecoder. readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)Reads an encodedBinaryvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.ProtonBufferStreamDecoder. readBinaryAsBuffer(java.io.InputStream stream, StreamDecoderState state)Reads an encodedBinaryvalue from the givenInputStreamassuming 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.StringDecoderState. decodeUTF8(ProtonBuffer buffer, int length)Given a set of UTF-8 encoded bytes decode and return the String that represents that UTF-8 value.ProtonBufferEncoderState. 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 givenProtonBufferinstance and returns aTypeDecoderthat 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.BinaryDecoder. readBinary(ProtonBuffer buffer, DecoderState state)Reads an encodedBinaryvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.ProtonBufferDecoder. readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)Reads an encodedBinaryvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.BooleanDecoder. readBoolean(ProtonBuffer buffer, DecoderState state)Reads an encodedBooleanvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.booleanDecoder. readBoolean(ProtonBuffer buffer, DecoderState state, boolean defaultValue)Reads an encodedBytevalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.ByteDecoder. readByte(ProtonBuffer buffer, DecoderState state)Reads an encodedBytevalue from the givenProtonBufferassuming that the next value in the byte stream is that type.byteDecoder. readByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)Reads an encodedBytevalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.CharacterDecoder. readCharacter(ProtonBuffer buffer, DecoderState state)Reads an encodedCharactervalue from the givenProtonBufferassuming that the next value in the byte stream is that type.charDecoder. readCharacter(ProtonBuffer buffer, DecoderState state, char defaultValue)Reads an encodedCharactervalue from the givenProtonBufferassuming that the next value in the byte stream is that type.Decimal128Decoder. readDecimal128(ProtonBuffer buffer, DecoderState state)Reads an encodedDecimal128value from the givenProtonBufferassuming that the next value in the byte stream is that type.Decimal32Decoder. readDecimal32(ProtonBuffer buffer, DecoderState state)Reads an encodedDecimal32value from the givenProtonBufferassuming that the next value in the byte stream is that type.Decimal64Decoder. readDecimal64(ProtonBuffer buffer, DecoderState state)Reads an encodedDecimal64value from the givenProtonBufferassuming that the next value in the byte stream is that type.DeliveryTagDecoder. readDeliveryTag(ProtonBuffer buffer, DecoderState state)This method expects to read aBinaryencoded type from the provided buffer and constructs aDeliveryTagtype that wraps the bytes encoded.java.lang.DoubleDecoder. readDouble(ProtonBuffer buffer, DecoderState state)Reads an encodedDoublevalue from the givenProtonBufferassuming that the next value in the byte stream is that type.doubleDecoder. readDouble(ProtonBuffer buffer, DecoderState state, double defaultValue)Reads an encodedDoublevalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.FloatDecoder. readFloat(ProtonBuffer buffer, DecoderState state)Reads an encodedFloatvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.floatDecoder. readFloat(ProtonBuffer buffer, DecoderState state, float defaultValue)Reads an encodedFloatvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.IntegerDecoder. readInteger(ProtonBuffer buffer, DecoderState state)Reads an encodedIntegervalue from the givenProtonBufferassuming that the next value in the byte stream is that type.intDecoder. readInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)Reads an encodedIntegervalue from the givenProtonBufferassuming that the next value in the byte stream is that type.<V> java.util.List<V>Decoder. readList(ProtonBuffer buffer, DecoderState state)Reads an encodedListvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.LongDecoder. readLong(ProtonBuffer buffer, DecoderState state)Reads an encodedLongvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.longDecoder. readLong(ProtonBuffer buffer, DecoderState state, long defaultValue)Reads an encodedLongvalue from the givenProtonBufferassuming 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 encodedMapvalue from the givenProtonBufferassuming 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 givenProtonBufferan return it as an array ofObjectinstances which the caller must then interpret.TypeDecoder<?>Decoder. readNextTypeDecoder(ProtonBuffer buffer, DecoderState state)Reads from the givenProtonBufferinstance and returns aTypeDecoderthat can read the next encoded AMQP type from the buffer's bytes.java.lang.ObjectDecoder. readObject(ProtonBuffer buffer, DecoderState state)Reads an encoded value from the givenProtonBufferan return it as anObjectwhich the caller must then interpret.<T> TDecoder. readObject(ProtonBuffer buffer, DecoderState state, java.lang.Class<T> clazz)Reads an encoded value from the givenProtonBufferan return it as anObjectwhich the caller must then interpret.java.lang.ShortDecoder. readShort(ProtonBuffer buffer, DecoderState state)Reads an encodedShortvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.shortDecoder. readShort(ProtonBuffer buffer, DecoderState state, short defaultValue)Reads an encodedShortvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.StringDecoder. readString(ProtonBuffer buffer, DecoderState state)Reads an encodedStringvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.SymbolDecoder. readSymbol(ProtonBuffer buffer, DecoderState state)Reads an encodedSymbolvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.StringDecoder. readSymbol(ProtonBuffer buffer, DecoderState state, java.lang.String defaultValue)Reads an encodedStringvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.lang.LongDecoder. readTimestamp(ProtonBuffer buffer, DecoderState state)Reads an encoded AMQP time stamp value from the givenProtonBufferassuming that the next value in the byte stream is that type.longDecoder. readTimestamp(ProtonBuffer buffer, DecoderState state, long defaultValue)Reads an encoded AMQP time stamp value from the givenProtonBufferassuming that the next value in the byte stream is that type.UnsignedByteDecoder. readUnsignedByte(ProtonBuffer buffer, DecoderState state)Reads an encodedUnsignedBytevalue from the givenProtonBufferassuming that the next value in the byte stream is that type.byteDecoder. readUnsignedByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)Reads an encodedUnsignedBytevalue from the givenProtonBufferassuming that the next value in the byte stream is that type.UnsignedIntegerDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state)Reads an encodedUnsignedIntegervalue from the givenProtonBufferassuming that the next value in the byte stream is that type.intDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)Reads an encodedUnsignedIntegervalue from the givenProtonBufferassuming that the next value in the byte stream is that type.longDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state, long defaultValue)Reads an encodedUnsignedIntegervalue from the givenProtonBufferassuming that the next value in the byte stream is that type.UnsignedLongDecoder. readUnsignedLong(ProtonBuffer buffer, DecoderState state)Reads an encodedUnsignedLongvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.longDecoder. readUnsignedLong(ProtonBuffer buffer, DecoderState state, long defaultValue)Reads an encodedUnsignedLongvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.UnsignedShortDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state)Reads an encodedUnsignedShortvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.intDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state, int defaultValue)Reads an encodedUnsignedShortvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.shortDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state, short defaultValue)Reads an encodedUnsignedShortvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.java.util.UUIDDecoder. readUUID(ProtonBuffer buffer, DecoderState state)Reads an encodedUUIDvalue from the givenProtonBufferassuming that the next value in the byte stream is that type.VTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)Reads the next type from the given buffer and returns it.voidTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)Skips over the bytes that compose the type this descriptor decodes.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, boolean[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, byte[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, char[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, double[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, float[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, int[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, long[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, short[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.util.UUID[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal128[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal32[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal64[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Symbol[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedByte[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedInteger[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedLong[] value)Write the given array as with the proper array type encoding to the given buffer.voidEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedShort[] value)Write the given array as with the proper array type encoding to the given buffer.voidTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)Write an array elements of the AMQP type to the given byte buffer.voidEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, byte[] value)Writes the contents of the givenbytevalue into the providedProtonBufferinstance as an AMQP Binary type.voidEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)Writes the contents of the givenProtonBuffervalue into the providedProtonBufferinstance as an AMQP Binary type.voidEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, Binary value)Writes the contents of the givenBinaryvalue into the providedProtonBufferinstance as an AMQP Binary type.voidEncoder. writeBoolean(ProtonBuffer buffer, EncoderState state, boolean value)Write aBooleantype encoding to the given buffer.voidEncoder. writeBoolean(ProtonBuffer buffer, EncoderState state, java.lang.Boolean value)Write aBooleantype encoding to the given buffer.voidEncoder. writeByte(ProtonBuffer buffer, EncoderState state, byte value)Write aBytetype encoding to the given buffer.voidEncoder. writeByte(ProtonBuffer buffer, EncoderState state, java.lang.Byte value)Write aBytetype encoding to the given buffer.voidEncoder. writeCharacter(ProtonBuffer buffer, EncoderState state, char value)Write aCharactertype encoding to the given buffer.voidEncoder. writeCharacter(ProtonBuffer buffer, EncoderState state, java.lang.Character value)Write aCharactertype encoding to the given buffer.voidEncoder. writeDecimal128(ProtonBuffer buffer, EncoderState state, Decimal128 value)Write aDecimal128type encoding to the given buffer.voidEncoder. writeDecimal32(ProtonBuffer buffer, EncoderState state, Decimal32 value)Write aDecimal32type encoding to the given buffer.voidEncoder. writeDecimal64(ProtonBuffer buffer, EncoderState state, Decimal64 value)Write aDecimal64type encoding to the given buffer.voidEncoder. writeDeliveryTag(ProtonBuffer buffer, EncoderState state, DeliveryTag value)Writes the contents of the givenDeliveryTagvalue into the providedProtonBufferinstance as an AMQP Binary type.voidEncoder. writeDescribedType(ProtonBuffer buffer, EncoderState state, DescribedType value)Write aDescribedTypetype encoding to the given buffer.voidEncoder. writeDouble(ProtonBuffer buffer, EncoderState state, double value)Write aDoubletype encoding to the given buffer.voidEncoder. writeDouble(ProtonBuffer buffer, EncoderState state, java.lang.Double value)Write aDoubletype encoding to the given buffer.voidEncoder. writeFloat(ProtonBuffer buffer, EncoderState state, float value)Write aFloattype encoding to the given buffer.voidEncoder. writeFloat(ProtonBuffer buffer, EncoderState state, java.lang.Float value)Write aFloattype encoding to the given buffer.voidEncoder. writeInteger(ProtonBuffer buffer, EncoderState state, int value)Write aIntegertype encoding to the given buffer.voidEncoder. writeInteger(ProtonBuffer buffer, EncoderState state, java.lang.Integer value)Write aIntegertype encoding to the given buffer.<T> voidEncoder. writeList(ProtonBuffer buffer, EncoderState state, java.util.List<T> value)Write aListtype encoding to the given buffer.voidEncoder. writeLong(ProtonBuffer buffer, EncoderState state, long value)Write aLongtype encoding to the given buffer.voidEncoder. writeLong(ProtonBuffer buffer, EncoderState state, java.lang.Long value)Write aLongtype encoding to the given buffer.<K,V>
voidEncoder. writeMap(ProtonBuffer buffer, EncoderState state, java.util.Map<K,V> value)Write aMaptype encoding to the given buffer.voidEncoder. writeNull(ProtonBuffer buffer, EncoderState state)Write a Null type encoding to the given buffer.voidEncoder. writeObject(ProtonBuffer buffer, EncoderState state, java.lang.Object value)Write the proper type encoding for the providedObjectto the given buffer if anTypeEncodercan be found for it in the collection of registered type encoders..voidTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)Write an array elements of the AMQP type to the given byte buffer.voidEncoder. writeShort(ProtonBuffer buffer, EncoderState state, short value)Write aShorttype encoding to the given buffer.voidEncoder. writeShort(ProtonBuffer buffer, EncoderState state, java.lang.Short value)Write aShorttype encoding to the given buffer.voidEncoder. writeString(ProtonBuffer buffer, EncoderState state, java.lang.String value)Write aStringtype encoding to the given buffer.voidEncoder. writeSymbol(ProtonBuffer buffer, EncoderState state, java.lang.String value)Write aSymboltype encoding to the given buffer.voidEncoder. writeSymbol(ProtonBuffer buffer, EncoderState state, Symbol value)Write aSymboltype encoding to the given buffer.voidEncoder. writeTimestamp(ProtonBuffer buffer, EncoderState state, long value)Write a Time stamp type encoding to the given buffer.voidEncoder. writeTimestamp(ProtonBuffer buffer, EncoderState state, java.util.Date value)Write a Time stamp type encoding to the given buffer.voidTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, V value)Write the full AMQP type data to the given byte buffer.voidEncoder. writeUnsignedByte(ProtonBuffer buffer, EncoderState state, byte value)Write anUnsignedBytetype encoding to the given buffer.voidEncoder. writeUnsignedByte(ProtonBuffer buffer, EncoderState state, UnsignedByte value)Write anUnsignedBytetype encoding to the given buffer.voidEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, byte value)Write aUnsignedIntegertype encoding to the given buffer.voidEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, int value)Write aUnsignedIntegertype encoding to the given buffer.voidEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, long value)Write aUnsignedIntegertype encoding to the given buffer using the provided value with appropriate range checks to ensure invalid input is not accepted.voidEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)Write aUnsignedIntegertype encoding to the given buffer.voidEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, byte value)Write aUnsignedLongtype encoding to the given buffer.voidEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, long value)Write aUnsignedLongtype encoding to the given buffer.voidEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, UnsignedLong value)Write aUnsignedLongtype encoding to the given buffer.voidEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, int value)Write aUnsignedShorttype encoding to the given buffer using the provided value with appropriate range checks to ensure invalid input is not accepted.voidEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, short value)Write aUnsignedShorttype encoding to the given buffer.voidEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, UnsignedShort value)Write aUnsignedShorttype encoding to the given buffer.voidEncoder. writeUUID(ProtonBuffer buffer, EncoderState state, java.util.UUID value)Write aUUIDtype 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 ProtonBufferProtonDecoder. readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)ProtonBufferProtonStreamDecoder. 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.StringProtonDecoderState. decodeUTF8(ProtonBuffer buffer, int length)java.lang.StringUTF8Decoder. 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)BinaryProtonDecoder. readBinary(ProtonBuffer buffer, DecoderState state)ProtonBufferProtonDecoder. readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)java.lang.BooleanProtonDecoder. readBoolean(ProtonBuffer buffer, DecoderState state)booleanProtonDecoder. readBoolean(ProtonBuffer buffer, DecoderState state, boolean defaultValue)java.lang.ByteProtonDecoder. readByte(ProtonBuffer buffer, DecoderState state)byteProtonDecoder. readByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)java.lang.CharacterProtonDecoder. readCharacter(ProtonBuffer buffer, DecoderState state)charProtonDecoder. readCharacter(ProtonBuffer buffer, DecoderState state, char defaultValue)Decimal128ProtonDecoder. readDecimal128(ProtonBuffer buffer, DecoderState state)Decimal32ProtonDecoder. readDecimal32(ProtonBuffer buffer, DecoderState state)Decimal64ProtonDecoder. readDecimal64(ProtonBuffer buffer, DecoderState state)DeliveryTagProtonDecoder. readDeliveryTag(ProtonBuffer buffer, DecoderState state)java.lang.DoubleProtonDecoder. readDouble(ProtonBuffer buffer, DecoderState state)doubleProtonDecoder. readDouble(ProtonBuffer buffer, DecoderState state, double defaultValue)java.lang.FloatProtonDecoder. readFloat(ProtonBuffer buffer, DecoderState state)floatProtonDecoder. readFloat(ProtonBuffer buffer, DecoderState state, float defaultValue)java.lang.IntegerProtonDecoder. readInteger(ProtonBuffer buffer, DecoderState state)intProtonDecoder. readInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)<V> java.util.List<V>ProtonDecoder. readList(ProtonBuffer buffer, DecoderState state)java.lang.LongProtonDecoder. readLong(ProtonBuffer buffer, DecoderState state)longProtonDecoder. 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.ObjectProtonDecoder. readObject(ProtonBuffer buffer, DecoderState state)<T> TProtonDecoder. readObject(ProtonBuffer buffer, DecoderState state, java.lang.Class<T> clazz)java.lang.ShortProtonDecoder. readShort(ProtonBuffer buffer, DecoderState state)shortProtonDecoder. readShort(ProtonBuffer buffer, DecoderState state, short defaultValue)java.lang.StringProtonDecoder. readString(ProtonBuffer buffer, DecoderState state)SymbolProtonDecoder. readSymbol(ProtonBuffer buffer, DecoderState state)java.lang.StringProtonDecoder. readSymbol(ProtonBuffer buffer, DecoderState state, java.lang.String defaultValue)java.lang.LongProtonDecoder. readTimestamp(ProtonBuffer buffer, DecoderState state)longProtonDecoder. readTimestamp(ProtonBuffer buffer, DecoderState state, long defaultValue)UnsignedByteProtonDecoder. readUnsignedByte(ProtonBuffer buffer, DecoderState state)byteProtonDecoder. readUnsignedByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)UnsignedIntegerProtonDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state)intProtonDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)longProtonDecoder. readUnsignedInteger(ProtonBuffer buffer, DecoderState state, long defaultValue)UnsignedLongProtonDecoder. readUnsignedLong(ProtonBuffer buffer, DecoderState state)longProtonDecoder. readUnsignedLong(ProtonBuffer buffer, DecoderState state, long defaultValue)UnsignedShortProtonDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state)intProtonDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state, int defaultValue)shortProtonDecoder. readUnsignedShort(ProtonBuffer buffer, DecoderState state, short defaultValue)java.util.UUIDProtonDecoder. readUUID(ProtonBuffer buffer, DecoderState state)DescribedTypeUnknownDescribedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)voidUnknownDescribedTypeDecoder. 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)AcceptedAcceptedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)AmqpSequence<?>AmqpSequenceTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)AmqpValue<?>AmqpValueTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)ApplicationPropertiesApplicationPropertiesTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DataDataTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DeleteOnCloseDeleteOnCloseTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DeleteOnNoLinksOrMessagesDeleteOnNoLinksOrMessagesTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DeleteOnNoLinksDeleteOnNoLinksTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DeleteOnNoMessagesDeleteOnNoMessagesTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DeliveryAnnotationsDeliveryAnnotationsTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)FooterFooterTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)HeaderHeaderTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)MessageAnnotationsMessageAnnotationsTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)ModifiedModifiedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)PropertiesPropertiesTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)ReceivedReceivedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)RejectedRejectedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)ReleasedReleasedTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)SourceSourceTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)TargetTargetTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)voidAcceptedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidAmqpSequenceTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidAmqpValueTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidApplicationPropertiesTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDataTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDeleteOnCloseTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDeleteOnNoLinksOrMessagesTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDeleteOnNoLinksTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDeleteOnNoMessagesTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDeliveryAnnotationsTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidFooterTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidHeaderTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidMessageAnnotationsTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidModifiedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidPropertiesTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidReceivedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidRejectedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidReleasedTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidSourceTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidTargetTypeDecoder. 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 ProtonBufferAbstractBinaryTypeDecoder. readValueAsBuffer(java.io.InputStream stream, StreamDecoderState state)Read and decode an AMQPBinaryinto aProtonBufferinstance and return it.ProtonBufferAbstractBinaryTypeDecoder. readValueAsBuffer(ProtonBuffer buffer, DecoderState state)Read and decode an AMQPBinaryinto aProtonBufferinstance and return it.Methods in org.apache.qpid.protonj2.codec.decoders.primitives with parameters of type ProtonBuffer Modifier and Type Method Description protected abstract intAbstractArrayTypeDecoder. readCount(ProtonBuffer buffer)protected intArray32TypeDecoder. readCount(ProtonBuffer buffer)protected intArray8TypeDecoder. readCount(ProtonBuffer buffer)intList0TypeDecoder. readCount(ProtonBuffer buffer)intList32TypeDecoder. readCount(ProtonBuffer buffer)intList8TypeDecoder. readCount(ProtonBuffer buffer)intListTypeDecoder. readCount(ProtonBuffer buffer)Reads the number of elements contained in the encoded list from the providedProtonBuffer.intMap32TypeDecoder. readCount(ProtonBuffer buffer)intMap8TypeDecoder. readCount(ProtonBuffer buffer)intMapTypeDecoder. readCount(ProtonBuffer buffer)Reads the count of entries in the encoded Map.booleanBooleanFalseTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)booleanBooleanTrueTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)booleanBooleanTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.byteByteTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.charCharacterTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.doubleDoubleTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.floatFloatTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.intInteger32TypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.intInteger8TypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.longLong8TypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)longLongTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.shortShortTypeDecoder. readPrimitiveValue(ProtonBuffer buffer, DecoderState state)Reads the primitive value from the givenProtonBufferand returns it.protected abstract intAbstractArrayTypeDecoder. readSize(ProtonBuffer buffer)abstract intAbstractBinaryTypeDecoder. readSize(ProtonBuffer buffer)protected abstract intAbstractStringTypeDecoder. readSize(ProtonBuffer buffer)protected abstract intAbstractSymbolTypeDecoder. readSize(ProtonBuffer buffer)Subclasses must read the correct number of bytes from the buffer to determine the size of the encoded Symbol value.protected intArray32TypeDecoder. readSize(ProtonBuffer buffer)protected intArray8TypeDecoder. readSize(ProtonBuffer buffer)intBinary32TypeDecoder. readSize(ProtonBuffer buffer)intBinary8TypeDecoder. readSize(ProtonBuffer buffer)intBinaryTypeDecoder. readSize(ProtonBuffer buffer)Reads the encoded size value for the encoded binary payload and returns it.intList0TypeDecoder. readSize(ProtonBuffer buffer)intList32TypeDecoder. readSize(ProtonBuffer buffer)intList8TypeDecoder. readSize(ProtonBuffer buffer)intListTypeDecoder. readSize(ProtonBuffer buffer)Reads the size in bytes of the encoded list from the providedProtonBuffer.intMap32TypeDecoder. readSize(ProtonBuffer buffer)intMap8TypeDecoder. readSize(ProtonBuffer buffer)intMapTypeDecoder. readSize(ProtonBuffer buffer)Reads the encoded size of the underlying Map type.protected intString32TypeDecoder. readSize(ProtonBuffer buffer)protected intString8TypeDecoder. readSize(ProtonBuffer buffer)protected intSymbol32TypeDecoder. readSize(ProtonBuffer buffer)protected intSymbol8TypeDecoder. readSize(ProtonBuffer buffer)java.lang.StringAbstractSymbolTypeDecoder. readString(ProtonBuffer buffer, DecoderState state)Reads a String view of an encoded Symbol value from the given buffer.java.lang.ObjectAbstractArrayTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)BinaryAbstractBinaryTypeDecoder. 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.StringAbstractStringTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)SymbolAbstractSymbolTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.BooleanBooleanFalseTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.BooleanBooleanTrueTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.BooleanBooleanTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.ByteByteTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.CharacterCharacterTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)Decimal128Decimal128TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)Decimal32Decimal32TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)Decimal64Decimal64TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.DoubleDoubleTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.FloatFloatTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.IntegerInteger32TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.IntegerInteger8TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.util.List<java.lang.Object>List0TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.LongLong8TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.LongLongTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.VoidNullTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.ShortShortTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.lang.LongTimestampTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)UnsignedByteUnsignedByteTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)UnsignedIntegerUnsignedInteger0TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)UnsignedIntegerUnsignedInteger32TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)UnsignedIntegerUnsignedInteger8TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)UnsignedLongUnsignedLong0TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)UnsignedLongUnsignedLong64TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)UnsignedLongUnsignedLong8TypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)UnsignedShortUnsignedShortTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)java.util.UUIDUUIDTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)byte[]AbstractBinaryTypeDecoder. readValueAsArray(ProtonBuffer buffer, DecoderState state)Read and decode an AMQPBinaryinto a byte array instance and return it.ProtonBufferAbstractBinaryTypeDecoder. readValueAsBuffer(ProtonBuffer buffer, DecoderState state)Read and decode an AMQPBinaryinto aProtonBufferinstance and return it.voidAbstractArrayTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidAbstractBinaryTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidAbstractListTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidAbstractMapTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidAbstractStringTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidAbstractSymbolTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidBooleanFalseTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidBooleanTrueTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidBooleanTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidByteTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidCharacterTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDecimal128TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDecimal32TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDecimal64TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDoubleTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidFloatTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidInteger32TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidInteger8TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidList0TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidLong8TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidLongTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidNullTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidShortTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidTimestampTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUnsignedByteTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUnsignedInteger0TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUnsignedInteger32TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUnsignedInteger8TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUnsignedLong0TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUnsignedLong64TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUnsignedLong8TypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUnsignedShortTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidUUIDTypeDecoder. 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)SaslChallengeSaslChallengeTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)SaslInitSaslInitTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)SaslMechanismsSaslMechanismsTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)SaslOutcomeSaslOutcomeTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)SaslResponseSaslResponseTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)voidSaslChallengeTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidSaslInitTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidSaslMechanismsTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidSaslOutcomeTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidSaslResponseTypeDecoder. 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)CoordinatorCoordinatorTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DeclaredDeclaredTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DeclareDeclareTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DischargeDischargeTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)TransactionalStateTransactionStateTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)voidCoordinatorTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDeclaredTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDeclareTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDischargeTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidTransactionStateTypeDecoder. 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)AttachAttachTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)BeginBeginTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)CloseCloseTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DetachDetachTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)DispositionDispositionTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)EndEndTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)ErrorConditionErrorConditionTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)FlowFlowTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)OpenOpenTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)TransferTransferTypeDecoder. readValue(ProtonBuffer buffer, DecoderState state)voidAttachTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidBeginTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidCloseTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDetachTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidDispositionTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidEndTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidErrorConditionTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidFlowTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidOpenTypeDecoder. skipValue(ProtonBuffer buffer, DecoderState state)voidTransferTypeDecoder. 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 ProtonBufferProtonEncoderState. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)ProtonBufferUTF8Encoder. 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 ProtonBufferProtonEncoderState. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)ProtonBufferUTF8Encoder. encodeUTF8(ProtonBuffer buffer, java.lang.CharSequence sequence)Encodes the given sequence of characters in UTF8 to the given buffer.voidAbstractDescribedListTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidAbstractDescribedMapTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidAbstractPrimitiveTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidDeliveryTagEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, boolean[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, byte[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, char[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, double[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, float[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, int[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, long[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, short[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.util.UUID[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal128[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal32[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Decimal64[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, Symbol[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedByte[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedInteger[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedLong[] value)voidProtonEncoder. writeArray(ProtonBuffer buffer, EncoderState state, UnsignedShort[] value)voidUnknownDescribedTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] value)voidProtonEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, byte[] value)voidProtonEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)voidProtonEncoder. writeBinary(ProtonBuffer buffer, EncoderState state, Binary value)voidProtonEncoder. writeBoolean(ProtonBuffer buffer, EncoderState state, boolean value)voidProtonEncoder. writeBoolean(ProtonBuffer buffer, EncoderState state, java.lang.Boolean value)voidProtonEncoder. writeByte(ProtonBuffer buffer, EncoderState state, byte value)voidProtonEncoder. writeByte(ProtonBuffer buffer, EncoderState state, java.lang.Byte value)voidProtonEncoder. writeCharacter(ProtonBuffer buffer, EncoderState state, char value)voidProtonEncoder. writeCharacter(ProtonBuffer buffer, EncoderState state, java.lang.Character value)voidProtonEncoder. writeDecimal128(ProtonBuffer buffer, EncoderState state, Decimal128 value)voidProtonEncoder. writeDecimal32(ProtonBuffer buffer, EncoderState state, Decimal32 value)voidProtonEncoder. writeDecimal64(ProtonBuffer buffer, EncoderState state, Decimal64 value)voidProtonEncoder. writeDeliveryTag(ProtonBuffer buffer, EncoderState state, DeliveryTag value)voidProtonEncoder. writeDescribedType(ProtonBuffer buffer, EncoderState state, DescribedType value)voidProtonEncoder. writeDouble(ProtonBuffer buffer, EncoderState state, double value)voidProtonEncoder. writeDouble(ProtonBuffer buffer, EncoderState state, java.lang.Double value)abstract voidAbstractDescribedListTypeEncoder. writeElement(V source, int index, ProtonBuffer buffer, EncoderState state)Instructs the encoder to write the element identified with the given indexvoidProtonEncoder. writeFloat(ProtonBuffer buffer, EncoderState state, float value)voidProtonEncoder. writeFloat(ProtonBuffer buffer, EncoderState state, java.lang.Float value)voidProtonEncoder. writeInteger(ProtonBuffer buffer, EncoderState state, int value)voidProtonEncoder. writeInteger(ProtonBuffer buffer, EncoderState state, java.lang.Integer value)<T> voidProtonEncoder. writeList(ProtonBuffer buffer, EncoderState state, java.util.List<T> value)voidProtonEncoder. writeLong(ProtonBuffer buffer, EncoderState state, long value)voidProtonEncoder. writeLong(ProtonBuffer buffer, EncoderState state, java.lang.Long value)<K,V>
voidProtonEncoder. writeMap(ProtonBuffer buffer, EncoderState state, java.util.Map<K,V> value)abstract voidAbstractDescribedMapTypeEncoder. 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.voidProtonEncoder. writeNull(ProtonBuffer buffer, EncoderState state)voidProtonEncoder. writeObject(ProtonBuffer buffer, EncoderState state, java.lang.Object value)voidAbstractDescribedListTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidAbstractDescribedMapTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidDeliveryTagEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidUnknownDescribedTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidProtonEncoder. writeShort(ProtonBuffer buffer, EncoderState state, short value)voidProtonEncoder. writeShort(ProtonBuffer buffer, EncoderState state, java.lang.Short value)voidProtonEncoder. writeString(ProtonBuffer buffer, EncoderState state, java.lang.String value)voidProtonEncoder. writeSymbol(ProtonBuffer buffer, EncoderState state, java.lang.String value)voidProtonEncoder. writeSymbol(ProtonBuffer buffer, EncoderState state, Symbol value)voidProtonEncoder. writeTimestamp(ProtonBuffer buffer, EncoderState state, long value)voidProtonEncoder. writeTimestamp(ProtonBuffer buffer, EncoderState state, java.util.Date value)voidAbstractDescribedListTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, V value)voidAbstractDescribedMapTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, M value)voidDeliveryTagEncoder. writeType(ProtonBuffer buffer, EncoderState state, DeliveryTag value)voidUnknownDescribedTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, DescribedType value)voidProtonEncoder. writeUnsignedByte(ProtonBuffer buffer, EncoderState state, byte value)voidProtonEncoder. writeUnsignedByte(ProtonBuffer buffer, EncoderState state, UnsignedByte value)voidProtonEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, byte value)voidProtonEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, int value)voidProtonEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, long value)voidProtonEncoder. writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)voidProtonEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, byte value)voidProtonEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, long value)voidProtonEncoder. writeUnsignedLong(ProtonBuffer buffer, EncoderState state, UnsignedLong value)voidProtonEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, int value)voidProtonEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, short value)voidProtonEncoder. writeUnsignedShort(ProtonBuffer buffer, EncoderState state, UnsignedShort value)voidProtonEncoder. 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 voidAmqpSequenceTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidAmqpValueTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidDataTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidAcceptedTypeEncoder. writeElement(Accepted source, int index, ProtonBuffer buffer, EncoderState state)voidDeleteOnCloseTypeEncoder. writeElement(DeleteOnClose source, int index, ProtonBuffer buffer, EncoderState state)voidDeleteOnNoLinksOrMessagesTypeEncoder. writeElement(DeleteOnNoLinksOrMessages source, int index, ProtonBuffer buffer, EncoderState state)voidDeleteOnNoLinksTypeEncoder. writeElement(DeleteOnNoLinks source, int index, ProtonBuffer buffer, EncoderState state)voidDeleteOnNoMessagesTypeEncoder. writeElement(DeleteOnNoMessages source, int index, ProtonBuffer buffer, EncoderState state)voidHeaderTypeEncoder. writeElement(Header header, int index, ProtonBuffer buffer, EncoderState state)voidModifiedTypeEncoder. writeElement(Modified source, int index, ProtonBuffer buffer, EncoderState state)voidPropertiesTypeEncoder. writeElement(Properties properties, int index, ProtonBuffer buffer, EncoderState state)voidReceivedTypeEncoder. writeElement(Received source, int index, ProtonBuffer buffer, EncoderState state)voidRejectedTypeEncoder. writeElement(Rejected source, int index, ProtonBuffer buffer, EncoderState state)voidReleasedTypeEncoder. writeElement(Released source, int index, ProtonBuffer buffer, EncoderState state)voidSourceTypeEncoder. writeElement(Source source, int index, ProtonBuffer buffer, EncoderState state)voidTargetTypeEncoder. writeElement(Target target, int index, ProtonBuffer buffer, EncoderState state)voidApplicationPropertiesTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, ApplicationProperties value)voidDeliveryAnnotationsTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, DeliveryAnnotations value)voidFooterTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, Footer value)voidMessageAnnotationsTypeEncoder. writeMapEntries(ProtonBuffer buffer, EncoderState state, MessageAnnotations value)voidAmqpSequenceTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidAmqpValueTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidDataTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidAcceptedTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Accepted value)voidAmqpSequenceTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, AmqpSequence value)voidAmqpValueTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, AmqpValue value)voidDataTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Data value)voidReleasedTypeEncoder. 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 voidArrayTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidBooleanTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, boolean[] values)Write the full AMQP type data for the boolean array to the given byte buffer.voidByteTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, byte[] values)voidCharacterTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, char[] values)voidDoubleTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, double[] values)voidFloatTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, float[] values)voidIntegerTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, int[] values)voidLongTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, long[] values)voidNullTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] value)voidShortTypeEncoder. writeArray(ProtonBuffer buffer, EncoderState state, short[] values)voidArrayTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidBinaryTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidBooleanTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, boolean[] values)Write the AMQP type data to the given byte buffer without an type encoding metadatavoidBooleanTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidByteTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, byte[] values)voidByteTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidCharacterTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, char[] values)voidCharacterTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidDecimal128TypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidDecimal32TypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidDecimal64TypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidDoubleTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, double[] values)voidDoubleTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidFloatTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, float[] values)voidFloatTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidIntegerTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, int[] values)voidIntegerTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidListTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidLongTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, long[] values)voidLongTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidMapTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidNullTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidShortTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, short[] values)voidShortTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidStringTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidSymbolTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidTimestampTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidUnsignedByteTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidUnsignedIntegerTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidUnsignedLongTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidUnsignedShortTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidUUIDTypeEncoder. writeRawArray(ProtonBuffer buffer, EncoderState state, java.lang.Object[] values)voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, boolean[] value)Encodes the given array into the provided buffer for transmission.voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte[] value)Encodes the given array into the provided buffer for transmission.voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, char[] value)Encodes the given array into the provided buffer for transmission.voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, double[] value)Encodes the given array into the provided buffer for transmission.voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, float[] value)Encodes the given array into the provided buffer for transmission.voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, int[] value)Encodes the given array into the provided buffer for transmission.voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long[] value)Encodes the given array into the provided buffer for transmission.voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, short[] value)Encodes the given array into the provided buffer for transmission.voidArrayTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Object value)voidBinaryTypeEncoder. 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 aBinaryinstance.voidBinaryTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)Shortcut API that allows aProtonBufferto be directly encoded as an AMQP Binary type without the need to create aBinaryinstance.voidBinaryTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Binary value)voidBooleanTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, boolean value)Write the full AMQP type data for the boolean to the given byte buffer.voidBooleanTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Boolean value)voidByteTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte value)Write the full AMQP type data for the byte to the given byte buffer.voidByteTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Byte value)voidCharacterTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Character value)voidDecimal128TypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Decimal128 value)voidDecimal32TypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Decimal32 value)voidDecimal64TypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Decimal64 value)voidDoubleTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, double value)Write the full AMQP type data for the double to the given byte buffer.voidDoubleTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Double value)voidFloatTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, float value)Write the full AMQP type data for the float to the given byte buffer.voidFloatTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Float value)voidIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, int value)Write the full AMQP type data for the int to the given byte buffer.voidIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Integer value)voidListTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.util.List value)voidLongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long value)Write the full AMQP type data for the long to the given byte buffer.voidLongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Long value)voidMapTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.util.Map value)voidNullTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Void value)voidShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, short value)Write the full AMQP type data for the short to the given byte buffer.voidShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.Short value)voidStringTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.lang.String value)voidSymbolTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, Symbol value)voidTimestampTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long value)Write the full AMQP type data for the time-stamp to the given byte buffer.voidTimestampTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, java.util.Date value)voidUnsignedByteTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte value)Write the full AMQP type data for the byte to the given byte buffer.voidUnsignedByteTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, UnsignedByte value)voidUnsignedIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte value)Write the full AMQP type data for the unsigned int to the given byte buffer.voidUnsignedIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, int value)Write the full AMQP type data for the unsigned int to the given byte buffer.voidUnsignedIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long value)Write the full AMQP type data for the unsigned integer to the given byte buffer.voidUnsignedIntegerTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)voidUnsignedLongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, byte value)Write the full AMQP type data for the unsigned long to the given byte buffer.voidUnsignedLongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, long value)Write the full AMQP type data for the unsigned long to the given byte buffer.voidUnsignedLongTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, UnsignedLong value)voidUnsignedShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, int value)Write the full AMQP type data for the unsigned short to the given byte buffer.voidUnsignedShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, short value)Write the full AMQP type data for the unsigned short to the given byte buffer.voidUnsignedShortTypeEncoder. writeType(ProtonBuffer buffer, EncoderState state, UnsignedShort value)voidUUIDTypeEncoder. 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 voidSaslChallengeTypeEncoder. writeElement(SaslChallenge challenge, int index, ProtonBuffer buffer, EncoderState state)voidSaslInitTypeEncoder. writeElement(SaslInit init, int index, ProtonBuffer buffer, EncoderState state)voidSaslMechanismsTypeEncoder. writeElement(SaslMechanisms mechanisms, int index, ProtonBuffer buffer, EncoderState state)voidSaslOutcomeTypeEncoder. writeElement(SaslOutcome outcome, int index, ProtonBuffer buffer, EncoderState state)voidSaslResponseTypeEncoder. 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 voidCoordinatorTypeEncoder. writeElement(Coordinator coordinator, int index, ProtonBuffer buffer, EncoderState state)voidDeclaredTypeEncoder. writeElement(Declared declared, int index, ProtonBuffer buffer, EncoderState state)voidDeclareTypeEncoder. writeElement(Declare declare, int index, ProtonBuffer buffer, EncoderState state)voidDischargeTypeEncoder. writeElement(Discharge discharge, int index, ProtonBuffer buffer, EncoderState state)voidTransactionStateTypeEncoder. 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 voidAttachTypeEncoder. writeElement(Attach attach, int index, ProtonBuffer buffer, EncoderState state)voidBeginTypeEncoder. writeElement(Begin begin, int index, ProtonBuffer buffer, EncoderState state)voidCloseTypeEncoder. writeElement(Close close, int index, ProtonBuffer buffer, EncoderState state)voidDetachTypeEncoder. writeElement(Detach detach, int index, ProtonBuffer buffer, EncoderState state)voidDispositionTypeEncoder. writeElement(Disposition disposition, int index, ProtonBuffer buffer, EncoderState state)voidEndTypeEncoder. writeElement(End end, int index, ProtonBuffer buffer, EncoderState state)voidErrorConditionTypeEncoder. writeElement(ErrorCondition error, int index, ProtonBuffer buffer, EncoderState state)voidFlowTypeEncoder. writeElement(Flow flow, int index, ProtonBuffer buffer, EncoderState state)voidOpenTypeEncoder. writeElement(Open open, int index, ProtonBuffer buffer, EncoderState state)voidTransferTypeEncoder. 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 ProtonBufferPerformativeEnvelope. getPayload()ProtonBufferIncomingDelivery. 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 voidEngine. accept(ProtonBuffer input)Provide data input for this Engine from some external source.voidEngineHandlerContext. fireRead(ProtonBuffer buffer)Fires a read of ProtonBuffer events into the previous handler in theEnginePipelinefor further processing.EnginePipelineEnginePipeline. fireRead(ProtonBuffer input)Fires a read event consisting of the givenProtonBufferinto the pipeline starting from the lastEngineHandlerin the pipeline and moving through each until the incoming work is fully processed.voidEngineHandlerContext. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)Fires a write of ProtonBuffer events into the next handler in theEnginePipelinefor further processing.EnginePipelineEnginePipeline. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)Fires a write event consisting of the givenProtonBufferinto the pipeline starting from the firstEngineHandlerin the pipeline and moving through each until the outgoing work is fully processed.default voidEngineHandler. handleRead(EngineHandlerContext context, ProtonBuffer buffer)Handle the read of new incoming bytes from a remote sender.default voidEngineHandler. 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.EngineEngine. ingest(ProtonBuffer input)Provide data input for this Engine from some external source.IncomingDeliveryIncomingDelivery. 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.OutgoingDeliveryOutgoingDelivery. 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.OutgoingDeliveryOutgoingDelivery. 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.EAMQPPerformativeEnvelopePool. 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.OutgoingDeliveryOutgoingDelivery. 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 EngineEngine. outputConsumer(java.util.function.Consumer<ProtonBuffer> consumer)Sets aConsumerinstance that will be notified when data from the engine is ready to be written to some output sink (socket etc).EngineEngine. outputHandler(java.util.function.BiConsumer<ProtonBuffer,java.lang.Runnable> output)Sets aBiConsumerinstance that will be notified when data from the engine is ready to be written to some output sink (socket etc).default EngineEngine. 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 ProtonBufferProtonIncomingDelivery. readAll()ProtonBufferProtonSequentialTagGenerator.ProtonNumericDeliveryTag. tagBuffer()Methods in org.apache.qpid.protonj2.engine.impl with parameters of type ProtonBuffer Modifier and Type Method Description voidProtonEngineHandlerContext. fireRead(ProtonBuffer buffer)ProtonEnginePipelineProtonEnginePipeline. fireRead(ProtonBuffer input)ProtonEnginePipelineProxyProtonEnginePipelineProxy. fireRead(ProtonBuffer input)voidProtonEngineHandlerContext. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)ProtonEnginePipelineProtonEnginePipeline. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)ProtonEnginePipelineProxyProtonEnginePipelineProxy. fireWrite(ProtonBuffer buffer, java.lang.Runnable ioComplete)voidProtonConnection. handleAttach(Attach attach, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleAttach(Attach attach, ProtonBuffer payload, int channel, EngineHandlerContext context)voidProtonConnection. handleBegin(Begin begin, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleBegin(Begin begin, ProtonBuffer payload, int channel, EngineHandlerContext context)voidProtonConnection. handleClose(Close close, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleClose(Close close, ProtonBuffer payload, int channel, EngineHandlerContext context)voidProtonConnection. handleDetach(Detach detach, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleDetach(Detach detach, ProtonBuffer payload, int channel, EngineHandlerContext context)voidProtonConnection. handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, EngineHandlerContext context)voidProtonConnection. handleEnd(End end, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleEnd(End end, ProtonBuffer payload, int channel, EngineHandlerContext context)voidProtonConnection. handleFlow(Flow flow, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleFlow(Flow flow, ProtonBuffer payload, int channel, EngineHandlerContext context)voidProtonConnection. handleOpen(Open open, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleOpen(Open open, ProtonBuffer payload, int channel, EngineHandlerContext context)voidProtonFrameDecodingHandler. handleRead(EngineHandlerContext context, ProtonBuffer buffer)protected abstract ProtonIncomingDeliveryProtonLink. handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)protected ProtonIncomingDeliveryProtonReceiver. handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)protected ProtonIncomingDeliveryProtonSender. handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)voidProtonConnection. handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, ProtonEngine context)voidProtonPerformativeHandler. handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, EngineHandlerContext context)ProtonEngineProtonEngine. ingest(ProtonBuffer input)ProtonIncomingDeliveryProtonIncomingDelivery. readBytes(ProtonBuffer buffer)OutgoingDeliveryProtonOutgoingDelivery. streamBytes(ProtonBuffer buffer)OutgoingDeliveryProtonOutgoingDelivery. streamBytes(ProtonBuffer buffer, boolean complete)OutgoingDeliveryProtonOutgoingDelivery. writeBytes(ProtonBuffer buffer)voidProtonSequentialTagGenerator.ProtonNumericDeliveryTag. writeTo(ProtonBuffer buffer)Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type ProtonBuffer Modifier and Type Method Description ProtonEngineProtonEngine. 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 voidSaslClientListener. 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.voidSaslServerListener. 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.voidSaslClientListener. 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.voidSaslServerListener. handleSaslResponse(SaslServerContext context, ProtonBuffer response)Called when a SASL response frame has arrived from the client.SaslServerContextSaslServerContext. sendChallenge(ProtonBuffer challenge)Sends the SASL challenge defined by the SASL mechanism that is in use during this SASL negotiation.SaslClientContextSaslClientContext. 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.SaslServerContextSaslServerContext. sendOutcome(SaslOutcome outcome, ProtonBuffer additional)Sends a response to a server side challenge that comprises the challenge / response exchange for the chosen SASL mechanism.SaslClientContextSaslClientContext. 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 ProtonBufferAbstractMechanism. EMPTYMethods in org.apache.qpid.protonj2.engine.sasl.client with parameters of type ProtonBuffer Modifier and Type Method Description ProtonBufferAbstractMechanism. getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)ProtonBufferCramMD5Mechanism. getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)ProtonBufferMechanism. getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)Create a response based on a given challenge from the remote peer.ProtonBufferXOauth2Mechanism. getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)voidSaslAuthenticator. handleSaslChallenge(SaslClientContext context, ProtonBuffer challenge)voidSaslAuthenticator. 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.StringStringUtils. 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.StringStringUtils. toQuotedString(ProtonBuffer buffer, boolean appendIfTruncated)Converts the ProtonBuffer to a quoted string using a default max length before truncation value.static java.lang.StringStringUtils. 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 ProtonBufferBinary. asProtonBuffer()ProtonBufferDeliveryTag.ProtonDeliveryTag. tagBuffer()ProtonBufferDeliveryTag. tagBuffer()Returns a view of thisDeliveryTagobject as aProtonBuffer.Methods in org.apache.qpid.protonj2.types with parameters of type ProtonBuffer Modifier and Type Method Description static SymbolSymbol. getSymbol(ProtonBuffer symbolBytes)static SymbolSymbol. getSymbol(ProtonBuffer symbolBuffer, boolean copyOnCreate)voidDeliveryTag.ProtonDeliveryTag. writeTo(ProtonBuffer buffer)voidDeliveryTag. writeTo(ProtonBuffer buffer)Writes the tag as a sequence of bytes into the given buffer in the manner most efficient for the underlyingDeliveryTagimplementation.voidSymbol. writeTo(ProtonBuffer target)Writes the internalSymbolbytes 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 ProtonBufferSaslOutcome. getAdditionalData()ProtonBufferSaslChallenge. getChallenge()ProtonBufferSaslInit. getInitialResponse()ProtonBufferSaslResponse. getResponse()Methods in org.apache.qpid.protonj2.types.security with parameters of type ProtonBuffer Modifier and Type Method Description SaslOutcomeSaslOutcome. setAdditionalData(ProtonBuffer additionalData)SaslChallengeSaslChallenge. setChallenge(ProtonBuffer challenge)SaslInitSaslInit. setInitialResponse(ProtonBuffer initialResponse)SaslResponseSaslResponse. 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 ProtonBufferAMQPHeader. getBuffer()Methods in org.apache.qpid.protonj2.types.transport with parameters of type ProtonBuffer Modifier and Type Method Description default voidPerformative.PerformativeHandler. handleAttach(Attach attach, ProtonBuffer payload, int channel, E context)default voidPerformative.PerformativeHandler. handleBegin(Begin begin, ProtonBuffer payload, int channel, E context)default voidPerformative.PerformativeHandler. handleClose(Close close, ProtonBuffer payload, int channel, E context)default voidPerformative.PerformativeHandler. handleDetach(Detach detach, ProtonBuffer payload, int channel, E context)default voidPerformative.PerformativeHandler. handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, E context)default voidPerformative.PerformativeHandler. handleEnd(End end, ProtonBuffer payload, int channel, E context)default voidPerformative.PerformativeHandler. handleFlow(Flow flow, ProtonBuffer payload, int channel, E context)default voidPerformative.PerformativeHandler. handleOpen(Open open, ProtonBuffer payload, int channel, E context)default voidPerformative.PerformativeHandler. handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, E context)<E> voidAttach. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidBegin. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidClose. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidDetach. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidDisposition. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidEnd. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidFlow. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidOpen. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidPerformative. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)<E> voidTransfer. invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)TransferTransfer. 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)
-