Uses of Interface
org.apache.qpid.protonj2.buffer.ProtonBuffer

Packages that use ProtonBuffer

Package	Description
org.apache.qpid.protonj2.buffer
org.apache.qpid.protonj2.buffer.impl
org.apache.qpid.protonj2.buffer.netty
org.apache.qpid.protonj2.client
org.apache.qpid.protonj2.client.impl
org.apache.qpid.protonj2.client.transport
org.apache.qpid.protonj2.client.transport.netty4
org.apache.qpid.protonj2.client.transport.netty5
org.apache.qpid.protonj2.codec
org.apache.qpid.protonj2.codec.decoders
org.apache.qpid.protonj2.codec.decoders.messaging
org.apache.qpid.protonj2.codec.decoders.primitives
org.apache.qpid.protonj2.codec.decoders.security
org.apache.qpid.protonj2.codec.decoders.transactions
org.apache.qpid.protonj2.codec.decoders.transport
org.apache.qpid.protonj2.codec.encoders
org.apache.qpid.protonj2.codec.encoders.messaging
org.apache.qpid.protonj2.codec.encoders.primitives
org.apache.qpid.protonj2.codec.encoders.security
org.apache.qpid.protonj2.codec.encoders.transactions
org.apache.qpid.protonj2.codec.encoders.transport
org.apache.qpid.protonj2.engine
org.apache.qpid.protonj2.engine.impl
org.apache.qpid.protonj2.engine.sasl
org.apache.qpid.protonj2.engine.sasl.client
org.apache.qpid.protonj2.engine.util
org.apache.qpid.protonj2.types
org.apache.qpid.protonj2.types.messaging
org.apache.qpid.protonj2.types.security
org.apache.qpid.protonj2.types.transport

Uses of ProtonBuffer in org.apache.qpid.protonj2.buffer

Subinterfaces of ProtonBuffer in org.apache.qpid.protonj2.buffer

Modifier and Type	Interface	Description
interface	ProtonCompositeBuffer	Defines the API for a specialized buffer type that is a composite of other buffer instances which is presented as a single buffer view.

Methods in org.apache.qpid.protonj2.buffer that return ProtonBuffer

Modifier and Type	Method	Description
default ProtonBuffer	ProtonBuffer.advanceReadOffset(int length)	Adjusts the current getReadOffset() of this buffer by the specified length.
default ProtonBuffer	ProtonBuffer.advanceWriteOffset(int length)	Adjusts the current getWriteOffset() of this buffer by the specified length.
ProtonBuffer	ProtonBufferAllocator.allocate()	Create a new ProtonBuffer instance with default initial capacity.
ProtonBuffer	ProtonBufferAllocator.allocate(int initialCapacity)	Create a new ProtonBuffer instance with the given initial capacity and the implicit growth limit should be that of the underlying buffer implementations maximum capacity limit.
ProtonBuffer	ProtonBufferAllocator.allocateHeapBuffer()	Create a new ProtonBuffer instance with default initial capacity.
ProtonBuffer	ProtonBufferAllocator.allocateHeapBuffer(int initialCapacity)	Create a new ProtonBuffer instance with the given initial capacity and the implicit growth limit should be that of the underlying buffer implementations maximum capacity limit.
default ProtonBuffer	ProtonBuffer.clear()	Reset the read and write offsets to zero.
ProtonBuffer	ProtonBuffer.compact()	Moves the readable portion of the buffer to the beginning of the underlying buffer storage and possibly makes additional bytes available for writes before a buffer expansion would occur via an ensureWritable(int) call.
ProtonBuffer	ProtonBuffer.convertToReadOnly()	Converts this buffer instance to a read-only buffer, any write operation that is performed on this buffer following this call will fail.
default ProtonBuffer	ProtonBuffer.copy()	Create a deep copy of the readable bytes of this ProtonBuffer, the returned buffer can be modified without affecting the contents or position markers of this instance.
default ProtonBuffer	ProtonBuffer.copy(boolean readOnly)	Returns a copy of this buffer's readable bytes and sets the read-only state of the returned buffer based on the value of the read-only flag.
default ProtonBuffer	ProtonBuffer.copy(int index, int length)	Returns a copy of this buffer's sub-region.
ProtonBuffer	ProtonBuffer.copy(int index, int length, boolean readOnly)	Returns a copy of this buffer's sub-region.
default ProtonBuffer	ProtonBufferAllocator.copy(byte[] array)	Create a new ProtonBuffer that copies the given byte array.
ProtonBuffer	ProtonBufferAllocator.copy(byte[] array, int offset, int length)	Create a new ProtonBuffer that copies the given byte array using the provided offset and length values to confine the view of that array.
default ProtonBuffer	ProtonBuffer.ensureWritable(int amount)	Ensures that the requested number of bytes is available for write operations in the current buffer, growing the buffer if needed to meet the requested writable capacity.
ProtonBuffer	ProtonBuffer.ensureWritable(int amount, int minimumGrowth, boolean allowCompaction)	Ensures that the requested number of bytes is available for write operations in the current buffer, growing the buffer if needed to meet the requested writable capacity.
ProtonBuffer	ProtonBuffer.fill(byte value)	Assigns the given value to every byte in the buffer without respect for the buffer read or write offsets.
ProtonBuffer	ProtonBuffer.implicitGrowthLimit(int limit)	Configures the limit assigned to this buffer if one was set which controls how large the capacity of the buffer can grow implicitly via write calls.
ProtonBuffer	ProtonBufferAllocator.outputBuffer(int initialCapacity)	Create a new output ProtonBuffer instance with the given initial capacity and the implicit growth capacity should be that of the underlying buffer implementations limit.
default ProtonBuffer	ProtonBuffer.readBytes(byte[] destination, int offset, int length)	Read from this buffer, into the destination array, the given number of bytes.
default ProtonBuffer	ProtonBuffer.readBytes(ByteBuffer destination)	Read from this buffer, into the destination ByteBuffer This updates the read offset of this buffer and also the position of the destination ByteBuffer.
default ProtonBuffer	ProtonBuffer.readSplit(int length)	Splits this buffer at the read offset + the length given.
default ProtonBuffer	ProtonBufferAccessors.setBoolean(int index, boolean value)	Sets the boolean value at the given write index in this buffer's backing data store.
ProtonBuffer	ProtonBufferAccessors.setByte(int index, byte value)	Sets the byte value at the given write index in this buffer's backing data store.
ProtonBuffer	ProtonBufferAccessors.setChar(int index, char value)	Sets the char value at the given write index in this buffer's backing data store.
default ProtonBuffer	ProtonBufferAccessors.setDouble(int index, double value)	Sets the double value at the given write index in this buffer's backing data store.
default ProtonBuffer	ProtonBufferAccessors.setFloat(int index, float value)	Sets the float value at the given write index in this buffer's backing data store.
ProtonBuffer	ProtonBufferAccessors.setInt(int index, int value)	Sets the int value at the given write index in this buffer's backing data store.
ProtonBuffer	ProtonBufferAccessors.setLong(int index, long value)	Sets the long value at the given write index in this buffer's backing data store.
ProtonBuffer	ProtonBuffer.setReadOffset(int value)	Sets the read offset for this buffer.
ProtonBuffer	ProtonBufferAccessors.setShort(int index, short value)	Sets the short value at the given write index in this buffer's backing data store.
default ProtonBuffer	ProtonBufferAccessors.setUnsignedByte(int index, int value)	Sets the unsigned byte value at the given write index in this buffer's backing data store.
default ProtonBuffer	ProtonBufferAccessors.setUnsignedInt(int index, long value)	Sets the long value at the given write index in this buffer's backing data store.
default ProtonBuffer	ProtonBufferAccessors.setUnsignedShort(int index, int value)	Sets the short value at the given write index in this buffer's backing data store.
ProtonBuffer	ProtonBuffer.setWriteOffset(int value)	Sets the write offset for this buffer.
default ProtonBuffer	ProtonBuffer.split()	Splits this buffer at the write offset.
ProtonBuffer	ProtonBuffer.split(int splitOffset)	Splits this buffer at the given offset.
default ProtonBuffer	ProtonBufferAccessors.writeBoolean(boolean value)	Writes a single boolean to the buffer and advances the write index by one.
ProtonBuffer	ProtonBufferAccessors.writeByte(byte value)	Writes a single byte to the buffer and advances the write index by one.
default ProtonBuffer	ProtonBuffer.writeBytes(byte[] source)	Writes into this buffer, all the bytes from the given byte array.
default ProtonBuffer	ProtonBuffer.writeBytes(byte[] source, int offset, int length)	Writes into this buffer, the given number of bytes from the byte array.
default ProtonBuffer	ProtonBuffer.writeBytes(ByteBuffer source)	Writes into this buffer from the source ByteBuffer.
default ProtonBuffer	ProtonBuffer.writeBytes(ProtonBuffer source)	Writes into this buffer, all the readable bytes from the given buffer.
ProtonBuffer	ProtonBufferAccessors.writeChar(char value)	Writes a single character to the buffer and advances the write index by four.
default ProtonBuffer	ProtonBuffer.writeCharSequence(CharSequence source, Charset charset)	Writes into this buffer, all the bytes from the given source using the passed charset.
default ProtonBuffer	ProtonBufferAccessors.writeDouble(double value)	Writes a single double to the buffer and advances the write index by eight.
default ProtonBuffer	ProtonBufferAccessors.writeFloat(float value)	Writes a single float to the buffer and advances the write index by four.
ProtonBuffer	ProtonBufferAccessors.writeInt(int value)	Writes a single integer to the buffer and advances the write index by four.
ProtonBuffer	ProtonBufferAccessors.writeLong(long value)	Writes a single long to the buffer and advances the write index by eight.
ProtonBuffer	ProtonBufferAccessors.writeShort(short value)	Writes a single short to the buffer and advances the write index by two.
default ProtonBuffer	ProtonBuffer.writeSplit(int length)	Splits this buffer at the write offset + the length given.
default ProtonBuffer	ProtonBufferAccessors.writeUnsignedByte(int value)	Writes a single byte to the buffer and advances the write index by one.
default ProtonBuffer	ProtonBufferAccessors.writeUnsignedInt(long value)	Writes a single unsigned int to the buffer and advances the write index by four.
default ProtonBuffer	ProtonBufferAccessors.writeUnsignedShort(int value)	Writes a single short to the buffer using the input integer value and advances the write index by two.

Methods in org.apache.qpid.protonj2.buffer that return types with arguments of type ProtonBuffer

Modifier and Type	Method	Description
Iterable<ProtonBuffer>	ProtonCompositeBuffer.decomposeBuffer()	Splits the composite buffer up into a collection of buffers that comprise it and leaves this buffer in what is effectively a closed state.

Methods in org.apache.qpid.protonj2.buffer with parameters of type ProtonBuffer

Modifier and Type	Method	Description
ProtonCompositeBuffer	ProtonCompositeBuffer.append(ProtonBuffer buffer)	Appends the given buffer to this composite buffer if all the constraints on buffer composites are met, otherwise thrown an exception.
static void	ProtonBufferUtils.checkIsClosed(ProtonBuffer buffer)	Checks the given ProtonBuffer to see if it has already been closed.
static void	ProtonBufferUtils.checkIsReadOnly(ProtonBuffer buffer)	Checks the given ProtonBuffer to see if it has already been closed.
static int	ProtonBufferUtils.compare(ProtonBuffer lhs, ProtonBuffer rhs)	Compares two ProtonBuffer instances.
default int	ProtonBuffer.compareTo(ProtonBuffer buffer)	Compares the remaining content of the current buffer with the remaining content of the given buffer, which must not be null.
ProtonCompositeBuffer	ProtonBufferAllocator.composite(ProtonBuffer buffer)	Creates a new composite buffer instance that uses this allocator to create new backing space when the buffer writes exceed capacity or the ensure writable space API is used.
ProtonCompositeBuffer	ProtonBufferAllocator.composite(ProtonBuffer[] buffers)	Creates a new composite buffer instance that uses this allocator to create new backing space when the buffer writes exceed capacity or the ensure writable space API is used.
void	ProtonBuffer.copyInto(int offset, ProtonBuffer destination, int destOffset, int length)	Copies the given number of bytes from this buffer into the specified target ProtonBuffer starting at the given offset into this buffer.
static CharSequence	ProtonBufferUtils.copyToCharSequence(ProtonBuffer source, int offset, int length, Charset charset)	Copies the given length number of bytes from the provided buffer and returns a CharSequence that is comprised of the characters of that sequence using the provided Charset to make the transformation.
static ProtonCompositeBuffer	ProtonCompositeBuffer.create(ProtonBufferAllocator allocator, ProtonBuffer buffer)	Create an composite buffer with the given buffer instance as the initial buffer payload.
static ProtonCompositeBuffer	ProtonCompositeBuffer.create(ProtonBufferAllocator allocator, ProtonBuffer[] buffers)	Create an composite buffer with the given array of buffers as the initial buffer payload.
static boolean	ProtonBufferUtils.equals(ProtonBuffer left, int leftStartIndex, ProtonBuffer right, int rightStartIndex, int length)	Compares two ProtonBuffer instances for equality.
static boolean	ProtonBufferUtils.equals(ProtonBuffer left, ProtonBuffer right)	Compares two ProtonBuffer instances for equality.
static boolean	ProtonBufferUtils.equals(ProtonBuffer left, ProtonBuffer right, int length)	Compares two ProtonBuffer instances for equality.
static ProtonBufferClosedException	ProtonBufferUtils.genericBufferIsClosed(ProtonBuffer buffer)
static ProtonBufferReadOnlyException	ProtonBufferUtils.genericBufferIsReadOnly(ProtonBuffer buffer)
static IndexOutOfBoundsException	ProtonBufferUtils.genericOutOfBounds(ProtonBuffer buffer, int index)
static int	ProtonBufferUtils.hashCode(ProtonBuffer buffer)	Compute a hash code from the given ProtonBuffer.
static boolean	ProtonCompositeBuffer.isComposite(ProtonBuffer buffer)	Checks if the given buffer is an composite buffer instance or not.
static CharSequence	ProtonBufferUtils.readCharSequence(ProtonBuffer source, int length, Charset charset)	Reads a CharSequence from the given ProtonBuffer advancing the read offset by the length value provided.
static Cleaner.Cleanable	ProtonBufferUtils.registerCleanup(Object observed, ProtonBuffer buffer)	Register a cleanup watch on the given object which is related to the ProtonBuffer provided and ensure that if the object does not close the buffer by the time it becomes unreachable that the buffer is closed.
static byte[]	ProtonBufferUtils.toByteArray(ProtonBuffer buffer)	Given a ProtonBuffer returns an array containing a deep copy of the readable bytes from the provided buffer.
static ByteBuffer	ProtonBufferUtils.toByteBuffer(ProtonBuffer buffer)	Given a ProtonBuffer returns an ByteBuffer containing a copy of the readable bytes from the provided buffer.
static String	ProtonBufferUtils.toString(ProtonBuffer buffer, Charset charset)	Create a new String that is a copy of the boffer's readable bytes and is defined by the Charset provided.
default ProtonBuffer	ProtonBuffer.writeBytes(ProtonBuffer source)	Writes into this buffer, all the readable bytes from the given buffer.
default ProtonCompositeBuffer	ProtonCompositeBuffer.writeBytes(ProtonBuffer source)

Constructors in org.apache.qpid.protonj2.buffer with parameters of type ProtonBuffer

Modifier	Constructor	Description
	ProtonBufferInputStream(ProtonBuffer buffer)	Creates a new InputStream instance that wraps the given ProtonBuffer and assumes ownership.
	ProtonBufferOutputStream(ProtonBuffer buffer)	Create a new OutputStream which wraps the given buffer.

Uses of ProtonBuffer in org.apache.qpid.protonj2.buffer.impl

Classes in org.apache.qpid.protonj2.buffer.impl that implement ProtonBuffer

Modifier and Type	Class	Description
final class	ProtonByteArrayBuffer	An array based buffer implementation.
final class	ProtonCompositeBufferImpl	The built in composite buffer implementation.

Methods in org.apache.qpid.protonj2.buffer.impl that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	ProtonByteArrayBufferAllocator.allocate()
ProtonBuffer	ProtonByteArrayBufferAllocator.allocate(int initialCapacity)
ProtonBuffer	ProtonByteArrayBufferAllocator.allocateHeapBuffer()
ProtonBuffer	ProtonByteArrayBufferAllocator.allocateHeapBuffer(int initialCapacity)
ProtonBuffer	ProtonByteArrayBuffer.compact()
ProtonBuffer	ProtonByteArrayBuffer.copy(int offset, int length, boolean readOnly)
ProtonBuffer	ProtonByteArrayBufferAllocator.copy(byte[] array, int offset, int length)
ProtonBuffer	ProtonByteArrayBuffer.ensureWritable(int size, int minimumGrowth, boolean allowCompaction)
ProtonBuffer	ProtonByteArrayBuffer.fill(byte value)
ProtonBuffer	ProtonByteArrayBuffer.implicitGrowthLimit(int limit)
ProtonBuffer	ProtonByteArrayBufferAllocator.outputBuffer(int initialCapacity)
ProtonBuffer	ProtonByteArrayBuffer.readBytes(byte[] destination, int offset, int length)
ProtonBuffer	ProtonByteArrayBuffer.readBytes(ByteBuffer destination)
ProtonBuffer	ProtonByteArrayBuffer.setByte(int index, byte value)
ProtonBuffer	ProtonCompositeBufferImpl.setByte(int index, byte value)
ProtonBuffer	ProtonByteArrayBuffer.setChar(int index, char value)
ProtonBuffer	ProtonCompositeBufferImpl.setChar(int index, char value)
ProtonBuffer	ProtonByteArrayBuffer.setInt(int index, int value)
ProtonBuffer	ProtonCompositeBufferImpl.setInt(int index, int value)
ProtonBuffer	ProtonByteArrayBuffer.setLong(int index, long value)
ProtonBuffer	ProtonCompositeBufferImpl.setLong(int index, long value)
ProtonBuffer	ProtonByteArrayBuffer.setReadOffset(int value)
ProtonBuffer	ProtonByteArrayBuffer.setShort(int index, short value)
ProtonBuffer	ProtonCompositeBufferImpl.setShort(int index, short value)
ProtonBuffer	ProtonByteArrayBuffer.setWriteOffset(int value)
ProtonBuffer	ProtonByteArrayBuffer.split(int splitOffset)
protected ProtonBuffer	ProtonByteArrayBuffer.transferTheResource()
protected ProtonBuffer	ProtonCompositeBufferImpl.transferTheResource()
ProtonBuffer	ProtonByteArrayBuffer.unwrap()
ProtonBuffer	ProtonByteArrayBufferAllocator.wrap(byte[] array, int offset, int length)	Shallow copy of the given array segment used when the caller knows that they will not share the bytes wrapped with any other application code.
static ProtonBuffer	ProtonByteArrayBufferAllocator.wrapped(byte[] array)	Shallow copy of the given array segment used when the caller knows that they will not share the bytes wrapped with any other application code.
static ProtonBuffer	ProtonByteArrayBufferAllocator.wrapped(byte[] array, int offset, int length)	Shallow copy of the given array segment used when the caller knows that they will not share the bytes wrapped with any other application code.
ProtonBuffer	ProtonByteArrayBuffer.writeByte(byte value)
ProtonBuffer	ProtonCompositeBufferImpl.writeByte(byte value)
ProtonBuffer	ProtonByteArrayBuffer.writeBytes(byte[] source, int offset, int length)
ProtonBuffer	ProtonByteArrayBuffer.writeBytes(ProtonBuffer source)
ProtonBuffer	ProtonByteArrayBuffer.writeChar(char value)
ProtonBuffer	ProtonCompositeBufferImpl.writeChar(char value)
ProtonBuffer	ProtonByteArrayBuffer.writeInt(int value)
ProtonBuffer	ProtonCompositeBufferImpl.writeInt(int value)
ProtonBuffer	ProtonByteArrayBuffer.writeLong(long value)
ProtonBuffer	ProtonCompositeBufferImpl.writeLong(long value)
ProtonBuffer	ProtonByteArrayBuffer.writeShort(short value)
ProtonBuffer	ProtonCompositeBufferImpl.writeShort(short value)

Methods in org.apache.qpid.protonj2.buffer.impl that return types with arguments of type ProtonBuffer

Modifier and Type	Method	Description
Iterable<ProtonBuffer>	ProtonCompositeBufferImpl.decomposeBuffer()

Methods in org.apache.qpid.protonj2.buffer.impl with parameters of type ProtonBuffer

Modifier and Type	Method	Description
ProtonCompositeBuffer	ProtonCompositeBufferImpl.append(ProtonBuffer buffer)
ProtonCompositeBuffer	ProtonByteArrayBufferAllocator.composite(ProtonBuffer buffer)
ProtonCompositeBuffer	ProtonByteArrayBufferAllocator.composite(ProtonBuffer[] buffers)
void	ProtonByteArrayBuffer.copyInto(int offset, ProtonBuffer destination, int destOffset, int length)
void	ProtonCompositeBufferImpl.copyInto(int offset, ProtonBuffer destination, int destOffset, int length)
static ProtonCompositeBuffer	ProtonCompositeBufferImpl.create(ProtonBufferAllocator allocator, ProtonBuffer buffer)	Create an empty ProtonCompositeBuffer with the given allocator which will be used any time the buffer needs to allocate additional storage space for implicit write or explicit ensure writable calls.
static ProtonCompositeBuffer	ProtonCompositeBufferImpl.create(ProtonBufferAllocator allocator, ProtonBuffer[] buffers)	Create an empty ProtonCompositeBuffer with the given allocator which will be used any time the buffer needs to allocate additional storage space for implicit write or explicit ensure writable calls.
ProtonBuffer	ProtonByteArrayBuffer.writeBytes(ProtonBuffer source)
ProtonCompositeBuffer	ProtonCompositeBufferImpl.writeBytes(ProtonBuffer source)

Uses of ProtonBuffer in org.apache.qpid.protonj2.buffer.netty

Classes in org.apache.qpid.protonj2.buffer.netty that implement ProtonBuffer

Modifier and Type	Class	Description
final class	Netty4ToProtonBufferAdapter	Wrapper class for Netty 4 ByteBuf instances which provides a generic way for proton to interact with Netty 4 buffers.
final class	Netty5ToProtonBufferAdapter	Wrapper class for Netty 5 Buffer instances which provides a generic way for proton to interact with Netty 4 buffers.

Methods in org.apache.qpid.protonj2.buffer.netty that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	Netty4ToProtonBufferAdapter.compact()
ProtonBuffer	Netty5ToProtonBufferAdapter.compact()
ProtonBuffer	Netty4ToProtonBufferAdapter.convertToReadOnly()
ProtonBuffer	Netty5ToProtonBufferAdapter.convertToReadOnly()
ProtonBuffer	Netty4ToProtonBufferAdapter.copy(int index, int length, boolean readOnly)
ProtonBuffer	Netty5ToProtonBufferAdapter.copy(int index, int length, boolean readOnly)
ProtonBuffer	Netty4ToProtonBufferAdapter.ensureWritable(int size, int minimumGrowth, boolean allowCompaction)
ProtonBuffer	Netty5ToProtonBufferAdapter.ensureWritable(int size, int minimumGrowth, boolean allowCompaction)
ProtonBuffer	Netty4ToProtonBufferAdapter.fill(byte value)
ProtonBuffer	Netty5ToProtonBufferAdapter.fill(byte value)
ProtonBuffer	Netty4ToProtonBufferAdapter.implicitGrowthLimit(int limit)
ProtonBuffer	Netty5ToProtonBufferAdapter.implicitGrowthLimit(int limit)
ProtonBuffer	Netty4ToProtonBufferAdapter.readBytes(byte[] destination, int offset, int length)
ProtonBuffer	Netty4ToProtonBufferAdapter.readBytes(ByteBuffer destination)
ProtonBuffer	Netty4ToProtonBufferAdapter.setByte(int index, byte value)
ProtonBuffer	Netty5ToProtonBufferAdapter.setByte(int index, byte value)
ProtonBuffer	Netty4ToProtonBufferAdapter.setChar(int index, char value)
ProtonBuffer	Netty5ToProtonBufferAdapter.setChar(int index, char value)
ProtonBuffer	Netty4ToProtonBufferAdapter.setInt(int index, int value)
ProtonBuffer	Netty5ToProtonBufferAdapter.setInt(int index, int value)
ProtonBuffer	Netty4ToProtonBufferAdapter.setLong(int index, long value)
ProtonBuffer	Netty5ToProtonBufferAdapter.setLong(int index, long value)
ProtonBuffer	Netty4ToProtonBufferAdapter.setReadOffset(int value)
ProtonBuffer	Netty5ToProtonBufferAdapter.setReadOffset(int value)
ProtonBuffer	Netty4ToProtonBufferAdapter.setShort(int index, short value)
ProtonBuffer	Netty5ToProtonBufferAdapter.setShort(int index, short value)
ProtonBuffer	Netty4ToProtonBufferAdapter.setWriteOffset(int value)
ProtonBuffer	Netty5ToProtonBufferAdapter.setWriteOffset(int value)
ProtonBuffer	Netty4ToProtonBufferAdapter.split(int splitOffset)
ProtonBuffer	Netty5ToProtonBufferAdapter.split(int splitOffset)
protected ProtonBuffer	Netty4ToProtonBufferAdapter.transferTheResource()
protected ProtonBuffer	Netty5ToProtonBufferAdapter.transferTheResource()
ProtonBuffer	Netty4ToProtonBufferAdapter.writeByte(byte value)
ProtonBuffer	Netty5ToProtonBufferAdapter.writeByte(byte value)
ProtonBuffer	Netty4ToProtonBufferAdapter.writeBytes(byte[] source, int offset, int length)
ProtonBuffer	Netty4ToProtonBufferAdapter.writeBytes(ByteBuffer source)
ProtonBuffer	Netty4ToProtonBufferAdapter.writeBytes(ProtonBuffer source)
ProtonBuffer	Netty5ToProtonBufferAdapter.writeBytes(byte[] source, int offset, int length)
ProtonBuffer	Netty5ToProtonBufferAdapter.writeBytes(ByteBuffer source)
ProtonBuffer	Netty4ToProtonBufferAdapter.writeChar(char value)
ProtonBuffer	Netty5ToProtonBufferAdapter.writeChar(char value)
ProtonBuffer	Netty4ToProtonBufferAdapter.writeInt(int value)
ProtonBuffer	Netty5ToProtonBufferAdapter.writeInt(int value)
ProtonBuffer	Netty4ToProtonBufferAdapter.writeLong(long value)
ProtonBuffer	Netty5ToProtonBufferAdapter.writeLong(long value)
ProtonBuffer	Netty4ToProtonBufferAdapter.writeShort(short value)
ProtonBuffer	Netty5ToProtonBufferAdapter.writeShort(short value)

Methods in org.apache.qpid.protonj2.buffer.netty with parameters of type ProtonBuffer

Modifier and Type	Method	Description
int	Netty4ToProtonBufferAdapter.compareTo(ProtonBuffer buffer)
int	Netty5ToProtonBufferAdapter.compareTo(ProtonBuffer buffer)
ProtonCompositeBuffer	Netty4ProtonBufferAllocator.composite(ProtonBuffer buffer)
ProtonCompositeBuffer	Netty4ProtonBufferAllocator.composite(ProtonBuffer[] buffers)
ProtonCompositeBuffer	Netty5ProtonBufferAllocator.composite(ProtonBuffer buffer)
ProtonCompositeBuffer	Netty5ProtonBufferAllocator.composite(ProtonBuffer[] buffers)
void	Netty4ToProtonBufferAdapter.copyInto(int offset, ProtonBuffer destination, int destOffset, int length)
void	Netty5ToProtonBufferAdapter.copyInto(int offset, ProtonBuffer destination, int destOffset, int length)
ProtonBuffer	Netty4ToProtonBufferAdapter.writeBytes(ProtonBuffer source)

Constructors in org.apache.qpid.protonj2.buffer.netty with parameters of type ProtonBuffer

Modifier	Constructor	Description
	ProtonBufferToNetty5Adapter(ProtonBuffer resource)

Uses of ProtonBuffer in org.apache.qpid.protonj2.client

Methods in org.apache.qpid.protonj2.client that return ProtonBuffer

Modifier and Type	Method	Description
default ProtonBuffer	AdvancedMessage.encode(Map<String,Object> deliveryAnnotations)	Encodes the AdvancedMessage for transmission by the client.
ProtonBuffer	AdvancedMessage.encode(Map<String,Object> deliveryAnnotations, ProtonBufferAllocator allocator)	Encodes the AdvancedMessage for transmission by the client.

Uses of ProtonBuffer in org.apache.qpid.protonj2.client.impl

Methods in org.apache.qpid.protonj2.client.impl that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	ClientMessage.encode(Map<String,Object> deliveryAnnotations, ProtonBufferAllocator allocator)
ProtonBuffer	ClientStreamReceiverMessage.encode(Map<String,Object> deliveryAnnotations, ProtonBufferAllocator allocator)
static ProtonBuffer	ClientMessageSupport.encodeMessage(AdvancedMessage<?> message, Map<String,Object> deliveryAnnotations)
static ProtonBuffer	ClientMessageSupport.encodeMessage(AdvancedMessage<?> message, Map<String,Object> deliveryAnnotations, ProtonBufferAllocator allocator)
static ProtonBuffer	ClientMessageSupport.encodeMessage(Encoder encoder, ProtonBufferAllocator allocator, AdvancedMessage<?> message, Map<String,Object> deliveryAnnotations)
static ProtonBuffer	ClientMessageSupport.encodeMessage(Encoder encoder, EncoderState encoderState, ProtonBufferAllocator allocator, AdvancedMessage<?> message, Map<String,Object> deliveryAnnotations)
static ProtonBuffer	ClientMessageSupport.encodeSection(Section<?> section, ProtonBuffer buffer)
ProtonBuffer	ClientStreamSender.ClientOutgoingEnvelope.payload()

Methods in org.apache.qpid.protonj2.client.impl with parameters of type ProtonBuffer

Modifier and Type	Method	Description
static Message<?>	ClientMessageSupport.decodeMessage(ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
static Message<?>	ClientMessageSupport.decodeMessage(Decoder decoder, ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
static Message<?>	ClientMessageSupport.decodeMessage(Decoder decoder, DecoderState decoderState, ProtonBuffer buffer, Consumer<DeliveryAnnotations> daConsumer)
static ProtonBuffer	ClientMessageSupport.encodeSection(Section<?> section, ProtonBuffer buffer)

Constructors in org.apache.qpid.protonj2.client.impl with parameters of type ProtonBuffer

Modifier	Constructor	Description
	ClientOutgoingEnvelope(ClientStreamSender sender, OutgoingDelivery delivery, int messageFormat, ProtonBuffer payload, boolean complete, ClientFuture<StreamTracker> 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
void	TransportListener.transportRead(ProtonBuffer incoming)	Called when new incoming data has become available for processing by the Transport user.
Transport	Transport.write(ProtonBuffer output)	Writes a chunk of data over the Transport connection without performing an explicit flush on the transport.
Transport	Transport.write(ProtonBuffer output, Runnable ioComplete)	Writes a chunk of data over the Transport connection without performing an explicit flush on the transport.
Transport	Transport.writeAndFlush(ProtonBuffer output)	Writes a chunk of data over the Transport connection and requests a flush of all pending queued write operations
Transport	Transport.writeAndFlush(ProtonBuffer output, Runnable ioComplete)	Writes a chunk of data over the Transport connection and requests a flush of all pending queued write operations

Uses of ProtonBuffer in org.apache.qpid.protonj2.client.transport.netty4

Methods in org.apache.qpid.protonj2.client.transport.netty4 with parameters of type ProtonBuffer

Modifier and Type	Method	Description
protected final io.netty.buffer.ByteBuf	TcpTransport.toOutputBuffer(ProtonBuffer output)
TcpTransport	TcpTransport.write(ProtonBuffer output)
TcpTransport	TcpTransport.write(ProtonBuffer output, Runnable onComplete)
WebSocketTransport	WebSocketTransport.write(ProtonBuffer output, Runnable onComplete)
TcpTransport	TcpTransport.writeAndFlush(ProtonBuffer output)
TcpTransport	TcpTransport.writeAndFlush(ProtonBuffer output, Runnable onComplete)
WebSocketTransport	WebSocketTransport.writeAndFlush(ProtonBuffer output, Runnable onComplete)

Uses of ProtonBuffer in org.apache.qpid.protonj2.client.transport.netty5

Methods in org.apache.qpid.protonj2.client.transport.netty5 with parameters of type ProtonBuffer

Modifier and Type	Method	Description
TcpTransport	TcpTransport.write(ProtonBuffer output)
TcpTransport	TcpTransport.write(ProtonBuffer output, Runnable onComplete)
TcpTransport	TcpTransport.writeAndFlush(ProtonBuffer output)
TcpTransport	TcpTransport.writeAndFlush(ProtonBuffer output, Runnable onComplete)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec

Methods in org.apache.qpid.protonj2.codec that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	EncoderState.encodeUTF8(ProtonBuffer buffer, CharSequence sequence)	Encodes the given sequence of characters in UTF8 to the given buffer.
ProtonBuffer	Decoder.readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)	Reads an encoded Binary value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
ProtonBuffer	StreamDecoder.readBinaryAsBuffer(InputStream stream, StreamDecoderState state)	Reads an encoded Binary value from the given InputStream assuming that the next value in the byte stream is that type.

Methods in org.apache.qpid.protonj2.codec with parameters of type ProtonBuffer

Modifier and Type	Method	Description
String	DecoderState.decodeUTF8(ProtonBuffer buffer, int length)	Given a set of UTF-8 encoded bytes decode and return the String that represents that UTF-8 value.
ProtonBuffer	EncoderState.encodeUTF8(ProtonBuffer buffer, CharSequence sequence)	Encodes the given sequence of characters in UTF8 to the given buffer.
void	PerformativeEncoder.handleAttach(Attach attach, ProtonBuffer target, int channel, Encoder encoder)
void	PerformativeEncoder.handleBegin(Begin begin, ProtonBuffer target, int channel, Encoder encoder)
void	PerformativeEncoder.handleClose(Close close, ProtonBuffer target, int channel, Encoder encoder)
void	PerformativeEncoder.handleDetach(Detach detach, ProtonBuffer target, int channel, Encoder encoder)
void	PerformativeEncoder.handleDisposition(Disposition disposition, ProtonBuffer target, int channel, Encoder encoder)
void	PerformativeEncoder.handleEnd(End end, ProtonBuffer target, int channel, Encoder encoder)
void	PerformativeEncoder.handleFlow(Flow flow, ProtonBuffer target, int channel, Encoder encoder)
void	PerformativeEncoder.handleOpen(Open open, ProtonBuffer target, int channel, Encoder encoder)
void	PerformativeEncoder.handleTransfer(Transfer transfer, ProtonBuffer target, int channel, Encoder encoder)
TypeDecoder<?>	Decoder.peekNextTypeDecoder(ProtonBuffer buffer, DecoderState state)	Peeks ahead in the given ProtonBuffer instance and returns a TypeDecoder that can read the next encoded AMQP type from the buffer's bytes.
V[]	TypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)	Reads a series of this type that have been encoded into the body of an Array type.
Binary	Decoder.readBinary(ProtonBuffer buffer, DecoderState state)	Reads an encoded Binary value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
ProtonBuffer	Decoder.readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)	Reads an encoded Binary value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Boolean	Decoder.readBoolean(ProtonBuffer buffer, DecoderState state)	Reads an encoded Boolean value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
boolean	Decoder.readBoolean(ProtonBuffer buffer, DecoderState state, boolean defaultValue)	Reads an encoded Byte value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Byte	Decoder.readByte(ProtonBuffer buffer, DecoderState state)	Reads an encoded Byte value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
byte	Decoder.readByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)	Reads an encoded Byte value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Character	Decoder.readCharacter(ProtonBuffer buffer, DecoderState state)	Reads an encoded Character value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
char	Decoder.readCharacter(ProtonBuffer buffer, DecoderState state, char defaultValue)	Reads an encoded Character value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Decimal128	Decoder.readDecimal128(ProtonBuffer buffer, DecoderState state)	Reads an encoded Decimal128 value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Decimal32	Decoder.readDecimal32(ProtonBuffer buffer, DecoderState state)	Reads an encoded Decimal32 value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Decimal64	Decoder.readDecimal64(ProtonBuffer buffer, DecoderState state)	Reads an encoded Decimal64 value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
DeliveryTag	Decoder.readDeliveryTag(ProtonBuffer buffer, DecoderState state)	This method expects to read a Binary encoded type from the provided buffer and constructs a DeliveryTag type that wraps the bytes encoded.
Double	Decoder.readDouble(ProtonBuffer buffer, DecoderState state)	Reads an encoded Double value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
double	Decoder.readDouble(ProtonBuffer buffer, DecoderState state, double defaultValue)	Reads an encoded Double value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Float	Decoder.readFloat(ProtonBuffer buffer, DecoderState state)	Reads an encoded Float value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
float	Decoder.readFloat(ProtonBuffer buffer, DecoderState state, float defaultValue)	Reads an encoded Float value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Integer	Decoder.readInteger(ProtonBuffer buffer, DecoderState state)	Reads an encoded Integer value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
int	Decoder.readInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)	Reads an encoded Integer value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
<V> List<V>	Decoder.readList(ProtonBuffer buffer, DecoderState state)	Reads an encoded List value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Long	Decoder.readLong(ProtonBuffer buffer, DecoderState state)	Reads an encoded Long value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
long	Decoder.readLong(ProtonBuffer buffer, DecoderState state, long defaultValue)	Reads an encoded Long value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
<K, V> Map<K,V>	Decoder.readMap(ProtonBuffer buffer, DecoderState state)	Reads an encoded Map value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
<T> T[]	Decoder.readMultiple(ProtonBuffer buffer, DecoderState state, Class<T> clazz)	Reads one or more encoded values from the given ProtonBuffer an return it as an array of Object instances which the caller must then interpret.
TypeDecoder<?>	Decoder.readNextTypeDecoder(ProtonBuffer buffer, DecoderState state)	Reads from the given ProtonBuffer instance and returns a TypeDecoder that can read the next encoded AMQP type from the buffer's bytes.
Object	Decoder.readObject(ProtonBuffer buffer, DecoderState state)	Reads an encoded value from the given ProtonBuffer an return it as an Object which the caller must then interpret.
<T> T	Decoder.readObject(ProtonBuffer buffer, DecoderState state, Class<T> clazz)	Reads an encoded value from the given ProtonBuffer an return it as an Object which the caller must then interpret.
Short	Decoder.readShort(ProtonBuffer buffer, DecoderState state)	Reads an encoded Short value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
short	Decoder.readShort(ProtonBuffer buffer, DecoderState state, short defaultValue)	Reads an encoded Short value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
int	TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)	Reads the size in bytes of the encoded AMQP type from the given buffer and returns it.
String	Decoder.readString(ProtonBuffer buffer, DecoderState state)	Reads an encoded String value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Symbol	Decoder.readSymbol(ProtonBuffer buffer, DecoderState state)	Reads an encoded Symbol value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
String	Decoder.readSymbol(ProtonBuffer buffer, DecoderState state, String defaultValue)	Reads an encoded String value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
Long	Decoder.readTimestamp(ProtonBuffer buffer, DecoderState state)	Reads an encoded AMQP time stamp value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
long	Decoder.readTimestamp(ProtonBuffer buffer, DecoderState state, long defaultValue)	Reads an encoded AMQP time stamp value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
UnsignedByte	Decoder.readUnsignedByte(ProtonBuffer buffer, DecoderState state)	Reads an encoded UnsignedByte value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
byte	Decoder.readUnsignedByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)	Reads an encoded UnsignedByte value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
UnsignedInteger	Decoder.readUnsignedInteger(ProtonBuffer buffer, DecoderState state)	Reads an encoded UnsignedInteger value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
int	Decoder.readUnsignedInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)	Reads an encoded UnsignedInteger value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
long	Decoder.readUnsignedInteger(ProtonBuffer buffer, DecoderState state, long defaultValue)	Reads an encoded UnsignedInteger value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
UnsignedLong	Decoder.readUnsignedLong(ProtonBuffer buffer, DecoderState state)	Reads an encoded UnsignedLong value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
long	Decoder.readUnsignedLong(ProtonBuffer buffer, DecoderState state, long defaultValue)	Reads an encoded UnsignedLong value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
UnsignedShort	Decoder.readUnsignedShort(ProtonBuffer buffer, DecoderState state)	Reads an encoded UnsignedShort value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
int	Decoder.readUnsignedShort(ProtonBuffer buffer, DecoderState state, int defaultValue)	Reads an encoded UnsignedShort value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
short	Decoder.readUnsignedShort(ProtonBuffer buffer, DecoderState state, short defaultValue)	Reads an encoded UnsignedShort value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
UUID	Decoder.readUUID(ProtonBuffer buffer, DecoderState state)	Reads an encoded UUID value from the given ProtonBuffer assuming that the next value in the byte stream is that type.
V	TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)	Reads the next type from the given buffer and returns it.
void	TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)	Skips over the bytes that compose the type this descriptor decodes.
void	SectionEncoder.write(ProtonBuffer buffer, ApplicationProperties properties)	Writes the given section using the cached encoder for that section types
void	SectionEncoder.write(ProtonBuffer buffer, DeliveryAnnotations annotations)	Writes the given section using the cached encoder for that section types
void	SectionEncoder.write(ProtonBuffer buffer, Footer footer)	Writes the given section using the cached encoder for that section types
void	SectionEncoder.write(ProtonBuffer buffer, Header header)	Writes the given section using the cached encoder for that section types
void	SectionEncoder.write(ProtonBuffer buffer, MessageAnnotations annotations)	Writes the given section using the cached encoder for that section types
void	SectionEncoder.write(ProtonBuffer buffer, Properties properties)	Writes the given section using the cached encoder for that section types
void	SectionEncoder.write(ProtonBuffer buffer, Section<?> section)	Writes the given section using the cached encoder for that section types
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, boolean[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, byte[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, char[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, double[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, float[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, int[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, long[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, short[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, UUID[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, Decimal128[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, Decimal32[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, Decimal64[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, Symbol[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, UnsignedByte[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, UnsignedInteger[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, UnsignedLong[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	Encoder.writeArray(ProtonBuffer buffer, EncoderState state, UnsignedShort[] value)	Write the given array as with the proper array type encoding to the given buffer.
void	TypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)	Write an array elements of the AMQP type to the given byte buffer.
void	Encoder.writeBinary(ProtonBuffer buffer, EncoderState state, byte[] value)	Writes the contents of the given byte value into the provided ProtonBuffer instance as an AMQP Binary type.
void	Encoder.writeBinary(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)	Writes the contents of the given ProtonBuffer value into the provided ProtonBuffer instance as an AMQP Binary type.
void	Encoder.writeBinary(ProtonBuffer buffer, EncoderState state, Binary value)	Writes the contents of the given Binary value into the provided ProtonBuffer instance as an AMQP Binary type.
void	Encoder.writeBoolean(ProtonBuffer buffer, EncoderState state, boolean value)	Write a Boolean type encoding to the given buffer.
void	Encoder.writeBoolean(ProtonBuffer buffer, EncoderState state, Boolean value)	Write a Boolean type encoding to the given buffer.
void	Encoder.writeByte(ProtonBuffer buffer, EncoderState state, byte value)	Write a Byte type encoding to the given buffer.
void	Encoder.writeByte(ProtonBuffer buffer, EncoderState state, Byte value)	Write a Byte type encoding to the given buffer.
void	Encoder.writeCharacter(ProtonBuffer buffer, EncoderState state, char value)	Write a Character type encoding to the given buffer.
void	Encoder.writeCharacter(ProtonBuffer buffer, EncoderState state, Character value)	Write a Character type encoding to the given buffer.
void	Encoder.writeDecimal128(ProtonBuffer buffer, EncoderState state, Decimal128 value)	Write a Decimal128 type encoding to the given buffer.
void	Encoder.writeDecimal32(ProtonBuffer buffer, EncoderState state, Decimal32 value)	Write a Decimal32 type encoding to the given buffer.
void	Encoder.writeDecimal64(ProtonBuffer buffer, EncoderState state, Decimal64 value)	Write a Decimal64 type encoding to the given buffer.
void	Encoder.writeDeliveryTag(ProtonBuffer buffer, EncoderState state, DeliveryTag value)	Writes the contents of the given DeliveryTag value into the provided ProtonBuffer instance as an AMQP Binary type.
void	Encoder.writeDescribedType(ProtonBuffer buffer, EncoderState state, DescribedType value)	Write a DescribedType type encoding to the given buffer.
void	Encoder.writeDouble(ProtonBuffer buffer, EncoderState state, double value)	Write a Double type encoding to the given buffer.
void	Encoder.writeDouble(ProtonBuffer buffer, EncoderState state, Double value)	Write a Double type encoding to the given buffer.
void	Encoder.writeFloat(ProtonBuffer buffer, EncoderState state, float value)	Write a Float type encoding to the given buffer.
void	Encoder.writeFloat(ProtonBuffer buffer, EncoderState state, Float value)	Write a Float type encoding to the given buffer.
void	Encoder.writeInteger(ProtonBuffer buffer, EncoderState state, int value)	Write a Integer type encoding to the given buffer.
void	Encoder.writeInteger(ProtonBuffer buffer, EncoderState state, Integer value)	Write a Integer type encoding to the given buffer.
<T> void	Encoder.writeList(ProtonBuffer buffer, EncoderState state, List<T> value)	Write a List type encoding to the given buffer.
void	Encoder.writeLong(ProtonBuffer buffer, EncoderState state, long value)	Write a Long type encoding to the given buffer.
void	Encoder.writeLong(ProtonBuffer buffer, EncoderState state, Long value)	Write a Long type encoding to the given buffer.
<K, V> void	Encoder.writeMap(ProtonBuffer buffer, EncoderState state, Map<K,V> value)	Write a Map type encoding to the given buffer.
void	Encoder.writeNull(ProtonBuffer buffer, EncoderState state)	Write a Null type encoding to the given buffer.
void	Encoder.writeObject(ProtonBuffer buffer, EncoderState state, Object value)	Write the proper type encoding for the provided Object to the given buffer if an TypeEncoder can be found for it in the collection of registered type encoders..
void	TypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)	Write an array elements of the AMQP type to the given byte buffer.
void	Encoder.writeShort(ProtonBuffer buffer, EncoderState state, short value)	Write a Short type encoding to the given buffer.
void	Encoder.writeShort(ProtonBuffer buffer, EncoderState state, Short value)	Write a Short type encoding to the given buffer.
void	Encoder.writeString(ProtonBuffer buffer, EncoderState state, String value)	Write a String type encoding to the given buffer.
void	Encoder.writeSymbol(ProtonBuffer buffer, EncoderState state, String value)	Write a Symbol type encoding to the given buffer.
void	Encoder.writeSymbol(ProtonBuffer buffer, EncoderState state, Symbol value)	Write a Symbol type encoding to the given buffer.
void	Encoder.writeTimestamp(ProtonBuffer buffer, EncoderState state, long value)	Write a Time stamp type encoding to the given buffer.
void	Encoder.writeTimestamp(ProtonBuffer buffer, EncoderState state, Date value)	Write a Time stamp type encoding to the given buffer.
void	TypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, V value)	Write the full AMQP type data to the given byte buffer.
void	Encoder.writeUnsignedByte(ProtonBuffer buffer, EncoderState state, byte value)	Write an UnsignedByte type encoding to the given buffer.
void	Encoder.writeUnsignedByte(ProtonBuffer buffer, EncoderState state, UnsignedByte value)	Write an UnsignedByte type encoding to the given buffer.
void	Encoder.writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, byte value)	Write a UnsignedInteger type encoding to the given buffer.
void	Encoder.writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, int value)	Write a UnsignedInteger type encoding to the given buffer.
void	Encoder.writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, long value)	Write a UnsignedInteger type encoding to the given buffer using the provided value with appropriate range checks to ensure invalid input is not accepted.
void	Encoder.writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)	Write a UnsignedInteger type encoding to the given buffer.
void	Encoder.writeUnsignedLong(ProtonBuffer buffer, EncoderState state, byte value)	Write a UnsignedLong type encoding to the given buffer.
void	Encoder.writeUnsignedLong(ProtonBuffer buffer, EncoderState state, long value)	Write a UnsignedLong type encoding to the given buffer.
void	Encoder.writeUnsignedLong(ProtonBuffer buffer, EncoderState state, UnsignedLong value)	Write a UnsignedLong type encoding to the given buffer.
void	Encoder.writeUnsignedShort(ProtonBuffer buffer, EncoderState state, int value)	Write a UnsignedShort type encoding to the given buffer using the provided value with appropriate range checks to ensure invalid input is not accepted.
void	Encoder.writeUnsignedShort(ProtonBuffer buffer, EncoderState state, short value)	Write a UnsignedShort type encoding to the given buffer.
void	Encoder.writeUnsignedShort(ProtonBuffer buffer, EncoderState state, UnsignedShort value)	Write a UnsignedShort type encoding to the given buffer.
void	Encoder.writeUUID(ProtonBuffer buffer, EncoderState state, UUID value)	Write a UUID type encoding to the given buffer.

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders

Methods in org.apache.qpid.protonj2.codec.decoders that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	ProtonDecoder.readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)
ProtonBuffer	ProtonStreamDecoder.readBinaryAsBuffer(InputStream stream, StreamDecoderState state)

Methods in org.apache.qpid.protonj2.codec.decoders with parameters of type ProtonBuffer

Modifier and Type	Method	Description
String	ProtonDecoderState.decodeUTF8(ProtonBuffer buffer, int length)
String	UTF8Decoder.decodeUTF8(ProtonBuffer buffer, int utf8length)	Decodes a String from the given UTF8 Bytes advancing the buffer read index by the given length value once complete.
boolean	ProtonScanningContext.matches(TypeDecoder<?> typeDecoder, ProtonBuffer candidate, int candidateLength, Consumer<Type> matchConsumer)
boolean	ScanningContext.matches(TypeDecoder<?> typeDecoder, ProtonBuffer candidate, int candidateLength, Consumer<Type> matchConsumer)	Returns true if the encoded entry bytes match against the search domain of the scan matching context and calls the provided match Consumer with the original unencoded form of the matched entry.
TypeDecoder<?>	ProtonDecoder.peekNextTypeDecoder(ProtonBuffer buffer, DecoderState state)
V[]	AbstractPrimitiveTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
final DescribedType[]	UnknownDescribedTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Binary	ProtonDecoder.readBinary(ProtonBuffer buffer, DecoderState state)
ProtonBuffer	ProtonDecoder.readBinaryAsBuffer(ProtonBuffer buffer, DecoderState state)
Boolean	ProtonDecoder.readBoolean(ProtonBuffer buffer, DecoderState state)
boolean	ProtonDecoder.readBoolean(ProtonBuffer buffer, DecoderState state, boolean defaultValue)
Byte	ProtonDecoder.readByte(ProtonBuffer buffer, DecoderState state)
byte	ProtonDecoder.readByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)
Character	ProtonDecoder.readCharacter(ProtonBuffer buffer, DecoderState state)
char	ProtonDecoder.readCharacter(ProtonBuffer buffer, DecoderState state, char defaultValue)
int	PrimitiveArrayTypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)	Reads the number of elements in the encoded primitive array from the given buffer and returns it.
Decimal128	ProtonDecoder.readDecimal128(ProtonBuffer buffer, DecoderState state)
Decimal32	ProtonDecoder.readDecimal32(ProtonBuffer buffer, DecoderState state)
Decimal64	ProtonDecoder.readDecimal64(ProtonBuffer buffer, DecoderState state)
DeliveryTag	ProtonDecoder.readDeliveryTag(ProtonBuffer buffer, DecoderState state)
Double	ProtonDecoder.readDouble(ProtonBuffer buffer, DecoderState state)
double	ProtonDecoder.readDouble(ProtonBuffer buffer, DecoderState state, double defaultValue)
Float	ProtonDecoder.readFloat(ProtonBuffer buffer, DecoderState state)
float	ProtonDecoder.readFloat(ProtonBuffer buffer, DecoderState state, float defaultValue)
Integer	ProtonDecoder.readInteger(ProtonBuffer buffer, DecoderState state)
int	ProtonDecoder.readInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)
<V> List<V>	ProtonDecoder.readList(ProtonBuffer buffer, DecoderState state)
Long	ProtonDecoder.readLong(ProtonBuffer buffer, DecoderState state)
long	ProtonDecoder.readLong(ProtonBuffer buffer, DecoderState state, long defaultValue)
<K, V> Map<K,V>	ProtonDecoder.readMap(ProtonBuffer buffer, DecoderState state)
<T> T[]	ProtonDecoder.readMultiple(ProtonBuffer buffer, DecoderState state, Class<T> clazz)
TypeDecoder<?>	ProtonDecoder.readNextTypeDecoder(ProtonBuffer buffer, DecoderState state)
Object	ProtonDecoder.readObject(ProtonBuffer buffer, DecoderState state)
<T> T	ProtonDecoder.readObject(ProtonBuffer buffer, DecoderState state, Class<T> clazz)
Short	ProtonDecoder.readShort(ProtonBuffer buffer, DecoderState state)
short	ProtonDecoder.readShort(ProtonBuffer buffer, DecoderState state, short defaultValue)
int	AbstractDescribedTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
String	ProtonDecoder.readString(ProtonBuffer buffer, DecoderState state)
Symbol	ProtonDecoder.readSymbol(ProtonBuffer buffer, DecoderState state)
String	ProtonDecoder.readSymbol(ProtonBuffer buffer, DecoderState state, String defaultValue)
Long	ProtonDecoder.readTimestamp(ProtonBuffer buffer, DecoderState state)
long	ProtonDecoder.readTimestamp(ProtonBuffer buffer, DecoderState state, long defaultValue)
UnsignedByte	ProtonDecoder.readUnsignedByte(ProtonBuffer buffer, DecoderState state)
byte	ProtonDecoder.readUnsignedByte(ProtonBuffer buffer, DecoderState state, byte defaultValue)
UnsignedInteger	ProtonDecoder.readUnsignedInteger(ProtonBuffer buffer, DecoderState state)
int	ProtonDecoder.readUnsignedInteger(ProtonBuffer buffer, DecoderState state, int defaultValue)
long	ProtonDecoder.readUnsignedInteger(ProtonBuffer buffer, DecoderState state, long defaultValue)
UnsignedLong	ProtonDecoder.readUnsignedLong(ProtonBuffer buffer, DecoderState state)
long	ProtonDecoder.readUnsignedLong(ProtonBuffer buffer, DecoderState state, long defaultValue)
UnsignedShort	ProtonDecoder.readUnsignedShort(ProtonBuffer buffer, DecoderState state)
int	ProtonDecoder.readUnsignedShort(ProtonBuffer buffer, DecoderState state, int defaultValue)
short	ProtonDecoder.readUnsignedShort(ProtonBuffer buffer, DecoderState state, short defaultValue)
UUID	ProtonDecoder.readUUID(ProtonBuffer buffer, DecoderState state)
final DescribedType	UnknownDescribedTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
protected <KeyType> void	AbstractDescribedMapTypeDecoder.scanMapEntries(ProtonBuffer buffer, DecoderState state, ScanningContext<KeyType> context, BiConsumer<KeyType,Object> matchConsumer)
final void	AbstractDescribedListTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
final void	AbstractDescribedMapTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
final void	UnknownDescribedTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)

Constructors in org.apache.qpid.protonj2.codec.decoders with parameters of type ProtonBuffer

Modifier	Constructor	Description
	ProtonScanningContext(Class<?> expectedType, Type entry, ProtonBuffer encodedEntry)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.messaging

Methods in org.apache.qpid.protonj2.codec.decoders.messaging with parameters of type ProtonBuffer

Modifier and Type	Method	Description
Accepted[]	AcceptedTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
AmqpSequence[]	AmqpSequenceTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
AmqpValue[]	AmqpValueTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
ApplicationProperties[]	ApplicationPropertiesTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Data[]	DataTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeleteOnClose[]	DeleteOnCloseTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeleteOnNoLinksOrMessages[]	DeleteOnNoLinksOrMessagesTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeleteOnNoLinks[]	DeleteOnNoLinksTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeleteOnNoMessages[]	DeleteOnNoMessagesTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
DeliveryAnnotations[]	DeliveryAnnotationsTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Footer[]	FooterTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Header[]	HeaderTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
MessageAnnotations[]	MessageAnnotationsTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Modified[]	ModifiedTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Properties[]	PropertiesTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Received[]	ReceivedTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Rejected[]	RejectedTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Released[]	ReleasedTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Source[]	SourceTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Target[]	TargetTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Accepted	AcceptedTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
AmqpSequence<?>	AmqpSequenceTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
AmqpValue<?>	AmqpValueTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
ApplicationProperties	ApplicationPropertiesTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Data	DataTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
DeleteOnClose	DeleteOnCloseTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
DeleteOnNoLinksOrMessages	DeleteOnNoLinksOrMessagesTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
DeleteOnNoLinks	DeleteOnNoLinksTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
DeleteOnNoMessages	DeleteOnNoMessagesTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
DeliveryAnnotations	DeliveryAnnotationsTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Footer	FooterTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Header	HeaderTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
MessageAnnotations	MessageAnnotationsTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Modified	ModifiedTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Properties	PropertiesTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Received	ReceivedTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Rejected	RejectedTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Released	ReleasedTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Source	SourceTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Target	TargetTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
void	DeliveryAnnotationsTypeDecoder.scanAnnotations(ProtonBuffer buffer, DecoderState state, ScanningContext<Symbol> context, BiConsumer<Symbol,Object> matchConsumer)	Scans through the encoded ApplicationProperties map looking for keys that match with the provided ScanningContext.
void	FooterTypeDecoder.scanAnnotations(ProtonBuffer buffer, DecoderState state, ScanningContext<Symbol> context, BiConsumer<Symbol,Object> matchConsumer)	Scans through the encoded Footer map looking for keys that match with the provided ScanningContext.
void	MessageAnnotationsTypeDecoder.scanAnnotations(ProtonBuffer buffer, DecoderState state, ScanningContext<Symbol> context, BiConsumer<Symbol,Object> matchConsumer)	Scans through the encoded MessageAnnotations map looking for keys that match with the provided ScanningContext.
void	ApplicationPropertiesTypeDecoder.scanProperties(ProtonBuffer buffer, DecoderState state, ScanningContext<String> context, BiConsumer<String,Object> matchConsumer)	Scans through the encoded ApplicationProperties map looking for keys that match with the provided ScanningContext.
void	AmqpSequenceTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	AmqpValueTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	DataTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.primitives

Methods in org.apache.qpid.protonj2.codec.decoders.primitives that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	AbstractBinaryTypeDecoder.readValueAsBuffer(InputStream stream, StreamDecoderState state)	Read and decode an AMQP Binary into a ProtonBuffer instance and return it.
ProtonBuffer	AbstractBinaryTypeDecoder.readValueAsBuffer(ProtonBuffer buffer, DecoderState state)	Read and decode an AMQP Binary into a ProtonBuffer instance and return it.

Methods in org.apache.qpid.protonj2.codec.decoders.primitives with parameters of type ProtonBuffer

Modifier and Type	Method	Description
int	Array32TypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)
int	Array8TypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)
int	List0TypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)
int	List32TypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)
int	List8TypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)
int	ListTypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)	Reads the number of elements contained in the encoded list from the provided ProtonBuffer.
int	Map32TypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)
int	Map8TypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)
int	MapTypeDecoder.readCount(ProtonBuffer buffer, DecoderState state)	Reads the count of entries in the encoded Map.
boolean	BooleanFalseTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
boolean	BooleanTrueTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
boolean	BooleanTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
byte	ByteTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
char	CharacterTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
double	DoubleTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
float	FloatTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
int	Integer32TypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
int	Integer8TypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
long	Long8TypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)
long	LongTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
short	ShortTypeDecoder.readPrimitiveValue(ProtonBuffer buffer, DecoderState state)	Reads the primitive value from the given ProtonBuffer and returns it.
int	Array32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Array8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Binary32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Binary8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	BooleanFalseTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	BooleanTrueTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	BooleanTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	ByteTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	CharacterTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Decimal128TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Decimal32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Decimal64TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	DoubleTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	FloatTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Integer32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Integer8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	List0TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	List32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	List8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Long8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	LongTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Map32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Map8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	NullTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	ShortTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	String32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	String8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Symbol32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	Symbol8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	TimestampTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UnsignedByteTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UnsignedInteger0TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UnsignedInteger32TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UnsignedInteger8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UnsignedLong0TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UnsignedLong64TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UnsignedLong8TypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UnsignedShortTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
int	UUIDTypeDecoder.readSize(ProtonBuffer buffer, DecoderState state)
String	AbstractSymbolTypeDecoder.readString(ProtonBuffer buffer, DecoderState state)	Reads a String view of an encoded Symbol value from the given buffer.
Object	AbstractArrayTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Binary	AbstractBinaryTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
List<Object>	AbstractListTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Map<Object,Object>	AbstractMapTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
String	AbstractStringTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Symbol	AbstractSymbolTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Boolean	BooleanFalseTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Boolean	BooleanTrueTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Boolean	BooleanTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Byte	ByteTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Character	CharacterTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Decimal128	Decimal128TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Decimal32	Decimal32TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Decimal64	Decimal64TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Double	DoubleTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Float	FloatTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Integer	Integer32TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Integer	Integer8TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
List<Object>	List0TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Long	Long8TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Long	LongTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Void	NullTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Short	ShortTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Long	TimestampTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UnsignedByte	UnsignedByteTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UnsignedInteger	UnsignedInteger0TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UnsignedInteger	UnsignedInteger32TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UnsignedInteger	UnsignedInteger8TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UnsignedLong	UnsignedLong0TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UnsignedLong	UnsignedLong64TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UnsignedLong	UnsignedLong8TypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UnsignedShort	UnsignedShortTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
UUID	UUIDTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
byte[]	AbstractBinaryTypeDecoder.readValueAsArray(ProtonBuffer buffer, DecoderState state)	Read and decode an AMQP Binary into a byte array instance and return it.
ProtonBuffer	AbstractBinaryTypeDecoder.readValueAsBuffer(ProtonBuffer buffer, DecoderState state)	Read and decode an AMQP Binary into a ProtonBuffer instance and return it.
<KeyType> void	AbstractMapTypeDecoder.scanKeys(ProtonBuffer buffer, DecoderState state, ScanningContext<KeyType> context, BiConsumer<KeyType,Object> matchConsumer)
<KeyType> void	MapTypeDecoder.scanKeys(ProtonBuffer buffer, DecoderState state, ScanningContext<KeyType> context, BiConsumer<KeyType,Object> matchConsumer)	Scan the encoded Map keys matching on predetermined key value encodings to quickly find mappings that are of interest and then only decoding the value portion of the matched key / value pair.
void	AbstractArrayTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	AbstractBinaryTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	AbstractListTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	AbstractMapTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	AbstractStringTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	AbstractSymbolTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	BooleanFalseTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	BooleanTrueTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	BooleanTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	ByteTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	CharacterTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	Decimal128TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	Decimal32TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	Decimal64TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	DoubleTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	FloatTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	Integer32TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	Integer8TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	List0TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	Long8TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	LongTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	NullTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	ShortTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	TimestampTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UnsignedByteTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UnsignedInteger0TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UnsignedInteger32TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UnsignedInteger8TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UnsignedLong0TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UnsignedLong64TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UnsignedLong8TypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UnsignedShortTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)
void	UUIDTypeDecoder.skipValue(ProtonBuffer buffer, DecoderState state)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.security

Methods in org.apache.qpid.protonj2.codec.decoders.security with parameters of type ProtonBuffer

Modifier and Type	Method	Description
SaslChallenge[]	SaslChallengeTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslInit[]	SaslInitTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslMechanisms[]	SaslMechanismsTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslOutcome[]	SaslOutcomeTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslResponse[]	SaslResponseTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
SaslChallenge	SaslChallengeTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
SaslInit	SaslInitTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
SaslMechanisms	SaslMechanismsTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
SaslOutcome	SaslOutcomeTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
SaslResponse	SaslResponseTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.transactions

Methods in org.apache.qpid.protonj2.codec.decoders.transactions with parameters of type ProtonBuffer

Modifier and Type	Method	Description
Coordinator[]	CoordinatorTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Declared[]	DeclaredTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Declare[]	DeclareTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Discharge[]	DischargeTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
TransactionalState[]	TransactionStateTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Coordinator	CoordinatorTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Declared	DeclaredTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Declare	DeclareTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Discharge	DischargeTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
TransactionalState	TransactionStateTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.decoders.transport

Methods in org.apache.qpid.protonj2.codec.decoders.transport with parameters of type ProtonBuffer

Modifier and Type	Method	Description
Attach[]	AttachTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Begin[]	BeginTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Close[]	CloseTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Detach[]	DetachTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Disposition[]	DispositionTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
End[]	EndTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
ErrorCondition[]	ErrorConditionTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Flow[]	FlowTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Open[]	OpenTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Transfer[]	TransferTypeDecoder.readArrayElements(ProtonBuffer buffer, DecoderState state, int count)
Attach	AttachTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Begin	BeginTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Close	CloseTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Detach	DetachTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Disposition	DispositionTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
End	EndTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
ErrorCondition	ErrorConditionTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Flow	FlowTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Open	OpenTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)
Transfer	TransferTypeDecoder.readValue(ProtonBuffer buffer, DecoderState state)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders

Methods in org.apache.qpid.protonj2.codec.encoders that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	ProtonEncoderState.encodeUTF8(ProtonBuffer buffer, CharSequence sequence)
ProtonBuffer	UTF8Encoder.encodeUTF8(ProtonBuffer buffer, CharSequence sequence)	Encodes the given sequence of characters in UTF8 to the given buffer.

Methods in org.apache.qpid.protonj2.codec.encoders with parameters of type ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	ProtonEncoderState.encodeUTF8(ProtonBuffer buffer, CharSequence sequence)
ProtonBuffer	UTF8Encoder.encodeUTF8(ProtonBuffer buffer, CharSequence sequence)	Encodes the given sequence of characters in UTF8 to the given buffer.
void	AbstractDescribedListTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	AbstractDescribedMapTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	AbstractPrimitiveTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	DeliveryTagEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, boolean[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, byte[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, char[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, double[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, float[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, int[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, long[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, short[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, UUID[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Decimal128[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Decimal32[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Decimal64[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Symbol[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, UnsignedByte[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, UnsignedInteger[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, UnsignedLong[] value)
void	ProtonEncoder.writeArray(ProtonBuffer buffer, EncoderState state, UnsignedShort[] value)
void	UnknownDescribedTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] value)
void	ProtonEncoder.writeBinary(ProtonBuffer buffer, EncoderState state, byte[] value)
void	ProtonEncoder.writeBinary(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)
void	ProtonEncoder.writeBinary(ProtonBuffer buffer, EncoderState state, Binary value)
void	ProtonEncoder.writeBoolean(ProtonBuffer buffer, EncoderState state, boolean value)
void	ProtonEncoder.writeBoolean(ProtonBuffer buffer, EncoderState state, Boolean value)
void	ProtonEncoder.writeByte(ProtonBuffer buffer, EncoderState state, byte value)
void	ProtonEncoder.writeByte(ProtonBuffer buffer, EncoderState state, Byte value)
void	ProtonEncoder.writeCharacter(ProtonBuffer buffer, EncoderState state, char value)
void	ProtonEncoder.writeCharacter(ProtonBuffer buffer, EncoderState state, Character value)
void	ProtonEncoder.writeDecimal128(ProtonBuffer buffer, EncoderState state, Decimal128 value)
void	ProtonEncoder.writeDecimal32(ProtonBuffer buffer, EncoderState state, Decimal32 value)
void	ProtonEncoder.writeDecimal64(ProtonBuffer buffer, EncoderState state, Decimal64 value)
void	ProtonEncoder.writeDeliveryTag(ProtonBuffer buffer, EncoderState state, DeliveryTag value)
void	ProtonEncoder.writeDescribedType(ProtonBuffer buffer, EncoderState state, DescribedType value)
void	ProtonEncoder.writeDouble(ProtonBuffer buffer, EncoderState state, double value)
void	ProtonEncoder.writeDouble(ProtonBuffer buffer, EncoderState state, Double value)
abstract void	AbstractDescribedListTypeEncoder.writeElement(V source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)	Instructs the encoder to write the element identified with the given index
void	ProtonEncoder.writeFloat(ProtonBuffer buffer, EncoderState state, float value)
void	ProtonEncoder.writeFloat(ProtonBuffer buffer, EncoderState state, Float value)
void	ProtonEncoder.writeInteger(ProtonBuffer buffer, EncoderState state, int value)
void	ProtonEncoder.writeInteger(ProtonBuffer buffer, EncoderState state, Integer value)
<T> void	ProtonEncoder.writeList(ProtonBuffer buffer, EncoderState state, List<T> value)
void	ProtonEncoder.writeLong(ProtonBuffer buffer, EncoderState state, long value)
void	ProtonEncoder.writeLong(ProtonBuffer buffer, EncoderState state, Long value)
<K, V> void	ProtonEncoder.writeMap(ProtonBuffer buffer, EncoderState state, Map<K,V> value)
abstract void	AbstractDescribedMapTypeEncoder.writeMapEntries(ProtonBuffer buffer, Encoder encoder, EncoderState state, M value)	Performs the write of the Map entries to the given buffer, the caller takes care of writing the Map preamble and tracking the final size of the written elements of the Map.
void	ProtonEncoder.writeNull(ProtonBuffer buffer, EncoderState state)
void	ProtonEncoder.writeObject(ProtonBuffer buffer, EncoderState state, Object value)
void	AbstractDescribedListTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	AbstractDescribedMapTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	DeliveryTagEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	UnknownDescribedTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	ProtonEncoder.writeShort(ProtonBuffer buffer, EncoderState state, short value)
void	ProtonEncoder.writeShort(ProtonBuffer buffer, EncoderState state, Short value)
void	ProtonEncoder.writeString(ProtonBuffer buffer, EncoderState state, String value)
void	ProtonEncoder.writeSymbol(ProtonBuffer buffer, EncoderState state, String value)
void	ProtonEncoder.writeSymbol(ProtonBuffer buffer, EncoderState state, Symbol value)
void	ProtonEncoder.writeTimestamp(ProtonBuffer buffer, EncoderState state, long value)
void	ProtonEncoder.writeTimestamp(ProtonBuffer buffer, EncoderState state, Date value)
void	AbstractDescribedListTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, V value)
void	AbstractDescribedMapTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, M value)
void	DeliveryTagEncoder.writeType(ProtonBuffer buffer, EncoderState state, DeliveryTag value)
void	UnknownDescribedTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, DescribedType value)
void	ProtonEncoder.writeUnsignedByte(ProtonBuffer buffer, EncoderState state, byte value)
void	ProtonEncoder.writeUnsignedByte(ProtonBuffer buffer, EncoderState state, UnsignedByte value)
void	ProtonEncoder.writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, byte value)
void	ProtonEncoder.writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, int value)
void	ProtonEncoder.writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, long value)
void	ProtonEncoder.writeUnsignedInteger(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)
void	ProtonEncoder.writeUnsignedLong(ProtonBuffer buffer, EncoderState state, byte value)
void	ProtonEncoder.writeUnsignedLong(ProtonBuffer buffer, EncoderState state, long value)
void	ProtonEncoder.writeUnsignedLong(ProtonBuffer buffer, EncoderState state, UnsignedLong value)
void	ProtonEncoder.writeUnsignedShort(ProtonBuffer buffer, EncoderState state, int value)
void	ProtonEncoder.writeUnsignedShort(ProtonBuffer buffer, EncoderState state, short value)
void	ProtonEncoder.writeUnsignedShort(ProtonBuffer buffer, EncoderState state, UnsignedShort value)
void	ProtonEncoder.writeUUID(ProtonBuffer buffer, EncoderState state, UUID value)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.messaging

Methods in org.apache.qpid.protonj2.codec.encoders.messaging with parameters of type ProtonBuffer

Modifier and Type	Method	Description
void	AmqpSequenceTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	AmqpValueTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	DataTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	AcceptedTypeEncoder.writeElement(Accepted source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DeleteOnCloseTypeEncoder.writeElement(DeleteOnClose source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DeleteOnNoLinksOrMessagesTypeEncoder.writeElement(DeleteOnNoLinksOrMessages source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DeleteOnNoLinksTypeEncoder.writeElement(DeleteOnNoLinks source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DeleteOnNoMessagesTypeEncoder.writeElement(DeleteOnNoMessages source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	HeaderTypeEncoder.writeElement(Header header, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	ModifiedTypeEncoder.writeElement(Modified source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	PropertiesTypeEncoder.writeElement(Properties properties, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	ReceivedTypeEncoder.writeElement(Received source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	RejectedTypeEncoder.writeElement(Rejected source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	ReleasedTypeEncoder.writeElement(Released source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	SourceTypeEncoder.writeElement(Source source, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	TargetTypeEncoder.writeElement(Target target, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	ApplicationPropertiesTypeEncoder.writeMapEntries(ProtonBuffer buffer, Encoder encoder, EncoderState state, ApplicationProperties properties)
void	DeliveryAnnotationsTypeEncoder.writeMapEntries(ProtonBuffer buffer, Encoder encoder, EncoderState state, DeliveryAnnotations annotations)
void	FooterTypeEncoder.writeMapEntries(ProtonBuffer buffer, Encoder encoder, EncoderState state, Footer footers)
void	MessageAnnotationsTypeEncoder.writeMapEntries(ProtonBuffer buffer, Encoder encoder, EncoderState state, MessageAnnotations annotations)
void	AmqpSequenceTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	AmqpValueTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	DataTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	AcceptedTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Accepted value)
void	AmqpSequenceTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, AmqpSequence value)
void	AmqpValueTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, AmqpValue value)
void	DataTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Data value)
void	ReleasedTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Released value)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.primitives

Methods in org.apache.qpid.protonj2.codec.encoders.primitives with parameters of type ProtonBuffer

Modifier and Type	Method	Description
void	ArrayTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	BooleanTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, boolean[] values)	Write the full AMQP type data for the boolean array to the given byte buffer.
void	ByteTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, byte[] values)
void	CharacterTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, char[] values)
void	DoubleTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, double[] values)
void	FloatTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, float[] values)
void	IntegerTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, int[] values)
void	LongTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, long[] values)
void	NullTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, Object[] value)
void	ShortTypeEncoder.writeArray(ProtonBuffer buffer, EncoderState state, short[] values)
void	ArrayTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	BinaryTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	BooleanTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, boolean[] values)	Write the AMQP type data to the given byte buffer without an type encoding metadata
void	BooleanTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	ByteTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, byte[] values)
void	ByteTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	CharacterTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, char[] values)
void	CharacterTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	Decimal128TypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	Decimal32TypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	Decimal64TypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	DoubleTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, double[] values)
void	DoubleTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	FloatTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, float[] values)
void	FloatTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	IntegerTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, int[] values)
void	IntegerTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	ListTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	LongTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, long[] values)
void	LongTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	MapTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	NullTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	ShortTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, short[] values)
void	ShortTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	StringTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	SymbolTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	TimestampTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	UnsignedByteTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	UnsignedIntegerTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	UnsignedLongTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	UnsignedShortTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	UUIDTypeEncoder.writeRawArray(ProtonBuffer buffer, EncoderState state, Object[] values)
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, boolean[] value)	Encodes the given array into the provided buffer for transmission.
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, byte[] value)	Encodes the given array into the provided buffer for transmission.
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, char[] value)	Encodes the given array into the provided buffer for transmission.
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, double[] value)	Encodes the given array into the provided buffer for transmission.
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, float[] value)	Encodes the given array into the provided buffer for transmission.
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, int[] value)	Encodes the given array into the provided buffer for transmission.
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, long[] value)	Encodes the given array into the provided buffer for transmission.
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, short[] value)	Encodes the given array into the provided buffer for transmission.
void	ArrayTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Object value)
void	BinaryTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, byte[] value)	Shortcut API that allows a byte[] to be directly encoded as an AMQP Binary type without the need to create a Binary instance.
void	BinaryTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, ProtonBuffer value)	Shortcut API that allows a ProtonBuffer to be directly encoded as an AMQP Binary type without the need to create a Binary instance.
void	BinaryTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Binary value)
void	BooleanTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, boolean value)	Write the full AMQP type data for the boolean to the given byte buffer.
void	BooleanTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Boolean value)
void	ByteTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, byte value)	Write the full AMQP type data for the byte to the given byte buffer.
void	ByteTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Byte value)
void	CharacterTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Character value)
void	Decimal128TypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Decimal128 value)
void	Decimal32TypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Decimal32 value)
void	Decimal64TypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Decimal64 value)
void	DoubleTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, double value)	Write the full AMQP type data for the double to the given byte buffer.
void	DoubleTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Double value)
void	FloatTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, float value)	Write the full AMQP type data for the float to the given byte buffer.
void	FloatTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Float value)
void	IntegerTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, int value)	Write the full AMQP type data for the int to the given byte buffer.
void	IntegerTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Integer value)
void	ListTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, List value)
void	LongTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, long value)	Write the full AMQP type data for the long to the given byte buffer.
void	LongTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Long value)
void	MapTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Map value)
void	NullTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Void value)
void	ShortTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, short value)	Write the full AMQP type data for the short to the given byte buffer.
void	ShortTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Short value)
void	StringTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, String value)
void	SymbolTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Symbol value)
void	TimestampTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, long value)	Write the full AMQP type data for the time-stamp to the given byte buffer.
void	TimestampTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, Date value)
void	UnsignedByteTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, byte value)	Write the full AMQP type data for the byte to the given byte buffer.
void	UnsignedByteTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, UnsignedByte value)
void	UnsignedIntegerTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, byte value)	Write the full AMQP type data for the unsigned int to the given byte buffer.
void	UnsignedIntegerTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, int value)	Write the full AMQP type data for the unsigned int to the given byte buffer.
void	UnsignedIntegerTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, long value)	Write the full AMQP type data for the unsigned integer to the given byte buffer.
void	UnsignedIntegerTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, UnsignedInteger value)
void	UnsignedLongTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, byte value)	Write the full AMQP type data for the unsigned long to the given byte buffer.
void	UnsignedLongTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, long value)	Write the full AMQP type data for the unsigned long to the given byte buffer.
void	UnsignedLongTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, UnsignedLong value)
void	UnsignedShortTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, int value)	Write the full AMQP type data for the unsigned short to the given byte buffer.
void	UnsignedShortTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, short value)	Write the full AMQP type data for the unsigned short to the given byte buffer.
void	UnsignedShortTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, UnsignedShort value)
void	UUIDTypeEncoder.writeType(ProtonBuffer buffer, EncoderState state, UUID value)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.security

Methods in org.apache.qpid.protonj2.codec.encoders.security with parameters of type ProtonBuffer

Modifier and Type	Method	Description
void	SaslChallengeTypeEncoder.writeElement(SaslChallenge challenge, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	SaslInitTypeEncoder.writeElement(SaslInit init, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	SaslMechanismsTypeEncoder.writeElement(SaslMechanisms mechanisms, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	SaslOutcomeTypeEncoder.writeElement(SaslOutcome outcome, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	SaslResponseTypeEncoder.writeElement(SaslResponse response, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.transactions

Methods in org.apache.qpid.protonj2.codec.encoders.transactions with parameters of type ProtonBuffer

Modifier and Type	Method	Description
void	CoordinatorTypeEncoder.writeElement(Coordinator coordinator, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DeclaredTypeEncoder.writeElement(Declared declared, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DeclareTypeEncoder.writeElement(Declare declare, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DischargeTypeEncoder.writeElement(Discharge discharge, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	TransactionStateTypeEncoder.writeElement(TransactionalState txState, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)

Uses of ProtonBuffer in org.apache.qpid.protonj2.codec.encoders.transport

Methods in org.apache.qpid.protonj2.codec.encoders.transport with parameters of type ProtonBuffer

Modifier and Type	Method	Description
void	AttachTypeEncoder.writeElement(Attach attach, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	BeginTypeEncoder.writeElement(Begin begin, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	CloseTypeEncoder.writeElement(Close close, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DetachTypeEncoder.writeElement(Detach detach, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	DispositionTypeEncoder.writeElement(Disposition disposition, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	EndTypeEncoder.writeElement(End end, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	ErrorConditionTypeEncoder.writeElement(ErrorCondition error, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	FlowTypeEncoder.writeElement(Flow flow, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	OpenTypeEncoder.writeElement(Open open, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)
void	TransferTypeEncoder.writeElement(Transfer transfer, int index, ProtonBuffer buffer, Encoder encoder, EncoderState state)

Uses of ProtonBuffer in org.apache.qpid.protonj2.engine

Methods in org.apache.qpid.protonj2.engine that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	PerformativeEnvelope.getPayload()
ProtonBuffer	IncomingDelivery.readAll()	Returns the current read buffer without copying it effectively consuming all currently available bytes from this delivery.

Methods in org.apache.qpid.protonj2.engine with parameters of type ProtonBuffer

Modifier and Type	Method	Description
default void	Engine.accept(ProtonBuffer input)	Provide data input for this Engine from some external source.
void	EngineHandlerContext.fireRead(ProtonBuffer buffer)	Fires a read of ProtonBuffer events into the previous handler in the EnginePipeline for further processing.
EnginePipeline	EnginePipeline.fireRead(ProtonBuffer input)	Fires a read event consisting of the given ProtonBuffer into the pipeline starting from the last EngineHandler in the pipeline and moving through each until the incoming work is fully processed.
void	EngineHandlerContext.fireWrite(ProtonBuffer buffer, Runnable ioComplete)	Fires a write of ProtonBuffer events into the next handler in the EnginePipeline for further processing.
EnginePipeline	EnginePipeline.fireWrite(ProtonBuffer buffer, Runnable ioComplete)	Fires a write event consisting of the given ProtonBuffer into the pipeline starting from the first EngineHandler in the pipeline and moving through each until the outgoing work is fully processed.
default void	EngineHandler.handleRead(EngineHandlerContext context, ProtonBuffer buffer)	Handle the read of new incoming bytes from a remote sender.
default void	EngineHandler.handleWrite(EngineHandlerContext context, ProtonBuffer buffer, Runnable ioComplete)	Writes the given bytes to the output target or if no handler in the pipeline handles this calls the registered output handler of the parent Engine instance.
Engine	Engine.ingest(ProtonBuffer input)	Provide data input for this Engine from some external source.
IncomingDelivery	IncomingDelivery.readBytes(ProtonBuffer buffer)	Reads bytes from this delivery and writes them into the destination ProtonBuffer reducing the available bytes by the value of the number of bytes written to the target.
OutgoingDelivery	OutgoingDelivery.streamBytes(ProtonBuffer buffer)	Write the given bytes as a portion of the payload of this delivery, additional bytes can be streamed until the stream complete flag is set to true on a call to OutgoingDelivery.streamBytes(ProtonBuffer, boolean) or a call to OutgoingDelivery.writeBytes(ProtonBuffer) is made.
OutgoingDelivery	OutgoingDelivery.streamBytes(ProtonBuffer buffer, boolean complete)	Write the given bytes as a portion of the payload of this delivery, additional bytes can be streamed until the stream complete flag is set to true on a call to OutgoingDelivery.streamBytes(ProtonBuffer, boolean) and the buffer contents on that send are fully written.
E	AMQPPerformativeEnvelopePool.take(Performative body, int channel, ProtonBuffer payload)	Requests an envelope from the pool and if non is available creates one using the given builder this pool was created with.
OutgoingDelivery	OutgoingDelivery.writeBytes(ProtonBuffer buffer)	Write the given bytes as the payload of this delivery, no additional writes can occur on this delivery if the write succeeds in sending all of the given bytes.

Method parameters in org.apache.qpid.protonj2.engine with type arguments of type ProtonBuffer

Modifier and Type	Method	Description
default Engine	Engine.outputConsumer(Consumer<ProtonBuffer> consumer)	Sets a Consumer instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).
Engine	Engine.outputHandler(BiConsumer<ProtonBuffer,Runnable> output)	Sets a BiConsumer instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).
default Engine	Engine.outputHandler(EventHandler<ProtonBuffer> output)	Sets a handler instance that will be notified when data from the engine is ready to be written to some output sink (socket etc).

Constructors in org.apache.qpid.protonj2.engine with parameters of type ProtonBuffer

Modifier	Constructor	Description
	SASLEnvelope(SaslPerformative performative, ProtonBuffer payload)	Creates a new SASL envelope that wraps the given SASL performative.

Uses of ProtonBuffer in org.apache.qpid.protonj2.engine.impl

Methods in org.apache.qpid.protonj2.engine.impl that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	ProtonIncomingDelivery.readAll()
ProtonBuffer	ProtonSequentialTagGenerator.ProtonNumericDeliveryTag.tagBuffer()

Methods in org.apache.qpid.protonj2.engine.impl with parameters of type ProtonBuffer

Modifier and Type	Method	Description
void	ProtonEngineHandlerContext.fireRead(ProtonBuffer buffer)
ProtonEnginePipeline	ProtonEnginePipeline.fireRead(ProtonBuffer input)
ProtonEnginePipelineProxy	ProtonEnginePipelineProxy.fireRead(ProtonBuffer input)
void	ProtonEngineHandlerContext.fireWrite(ProtonBuffer buffer, Runnable ioComplete)
ProtonEnginePipeline	ProtonEnginePipeline.fireWrite(ProtonBuffer buffer, Runnable ioComplete)
ProtonEnginePipelineProxy	ProtonEnginePipelineProxy.fireWrite(ProtonBuffer buffer, Runnable ioComplete)
void	ProtonConnection.handleAttach(Attach attach, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleAttach(Attach attach, ProtonBuffer payload, int channel, EngineHandlerContext context)
void	ProtonConnection.handleBegin(Begin begin, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleBegin(Begin begin, ProtonBuffer payload, int channel, EngineHandlerContext context)
void	ProtonConnection.handleClose(Close close, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleClose(Close close, ProtonBuffer payload, int channel, EngineHandlerContext context)
void	ProtonConnection.handleDetach(Detach detach, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleDetach(Detach detach, ProtonBuffer payload, int channel, EngineHandlerContext context)
void	ProtonConnection.handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, EngineHandlerContext context)
void	ProtonConnection.handleEnd(End end, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleEnd(End end, ProtonBuffer payload, int channel, EngineHandlerContext context)
void	ProtonConnection.handleFlow(Flow flow, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleFlow(Flow flow, ProtonBuffer payload, int channel, EngineHandlerContext context)
void	ProtonConnection.handleOpen(Open open, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleOpen(Open open, ProtonBuffer payload, int channel, EngineHandlerContext context)
void	ProtonFrameDecodingHandler.handleRead(EngineHandlerContext context, ProtonBuffer buffer)
protected abstract ProtonIncomingDelivery	ProtonLink.handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)
protected final ProtonIncomingDelivery	ProtonReceiver.handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)
protected final ProtonIncomingDelivery	ProtonSender.handleRemoteTransfer(Transfer transfer, ProtonBuffer payload)
void	ProtonConnection.handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, ProtonEngine context)
void	ProtonPerformativeHandler.handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, EngineHandlerContext context)
ProtonEngine	ProtonEngine.ingest(ProtonBuffer input)
ProtonIncomingDelivery	ProtonIncomingDelivery.readBytes(ProtonBuffer buffer)
OutgoingDelivery	ProtonOutgoingDelivery.streamBytes(ProtonBuffer buffer)
OutgoingDelivery	ProtonOutgoingDelivery.streamBytes(ProtonBuffer buffer, boolean complete)
OutgoingDelivery	ProtonOutgoingDelivery.writeBytes(ProtonBuffer buffer)
void	ProtonSequentialTagGenerator.ProtonNumericDeliveryTag.writeTo(ProtonBuffer buffer)

Method parameters in org.apache.qpid.protonj2.engine.impl with type arguments of type ProtonBuffer

Modifier and Type	Method	Description
ProtonEngine	ProtonEngine.outputHandler(BiConsumer<ProtonBuffer,Runnable> handler)

Uses of ProtonBuffer in org.apache.qpid.protonj2.engine.sasl

Methods in org.apache.qpid.protonj2.engine.sasl with parameters of type ProtonBuffer

Modifier and Type	Method	Description
void	SaslClientListener.handleSaslChallenge(SaslClientContext context, ProtonBuffer challenge)	Called when a SASL challenge frame has arrived and its effect applied, indicating the challenge sent by the 'server' peer.
void	SaslServerListener.handleSaslInit(SaslServerContext context, Symbol mechanism, ProtonBuffer initResponse)	Called when a SASL init frame has arrived from the client indicating the chosen SASL mechanism and the initial response data if any.
void	SaslClientListener.handleSaslOutcome(SaslClientContext context, SaslOutcome outcome, ProtonBuffer additional)	Called when a SASL outcome frame has arrived and its effect applied, indicating the outcome and any success additional data sent by the 'server' peer.
void	SaslServerListener.handleSaslResponse(SaslServerContext context, ProtonBuffer response)	Called when a SASL response frame has arrived from the client.
SaslServerContext	SaslServerContext.sendChallenge(ProtonBuffer challenge)	Sends the SASL challenge defined by the SASL mechanism that is in use during this SASL negotiation.
default SaslClientContext	SaslClientContext.sendChosenMechanism(String mechanism, 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.
SaslClientContext	SaslClientContext.sendChosenMechanism(Symbol mechanism, String host, ProtonBuffer initialResponse)	Sends a response to the SASL server indicating the chosen mechanism for this client and the host name that this client is identifying itself as.
SaslServerContext	SaslServerContext.sendOutcome(SaslOutcome outcome, ProtonBuffer additional)	Sends a response to a server side challenge that comprises the challenge / response exchange for the chosen SASL mechanism.
SaslClientContext	SaslClientContext.sendResponse(ProtonBuffer response)	Sends a response to a server side challenge that comprises the challenge / response exchange for the chosen SASL mechanism.

Uses of ProtonBuffer in org.apache.qpid.protonj2.engine.sasl.client

Fields in org.apache.qpid.protonj2.engine.sasl.client declared as ProtonBuffer

Modifier and Type	Field	Description
protected static final ProtonBuffer	AbstractMechanism.EMPTY

Methods in org.apache.qpid.protonj2.engine.sasl.client that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	AbstractMechanism.getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
ProtonBuffer	CramMD5Mechanism.getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
ProtonBuffer	Mechanism.getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)	Create a response based on a given challenge from the remote peer.
ProtonBuffer	XOauth2Mechanism.getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
ProtonBuffer	AbstractMechanism.getInitialResponse(SaslCredentialsProvider credentials)
ProtonBuffer	CramMD5Mechanism.getInitialResponse(SaslCredentialsProvider credentials)
ProtonBuffer	Mechanism.getInitialResponse(SaslCredentialsProvider credentials)	Create an initial response based on selected mechanism.
ProtonBuffer	PlainMechanism.getInitialResponse(SaslCredentialsProvider credentials)
ProtonBuffer	XOauth2Mechanism.getInitialResponse(SaslCredentialsProvider credentials)

Methods in org.apache.qpid.protonj2.engine.sasl.client with parameters of type ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	AbstractMechanism.getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
ProtonBuffer	CramMD5Mechanism.getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
ProtonBuffer	Mechanism.getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)	Create a response based on a given challenge from the remote peer.
ProtonBuffer	XOauth2Mechanism.getChallengeResponse(SaslCredentialsProvider credentials, ProtonBuffer challenge)
void	SaslAuthenticator.handleSaslChallenge(SaslClientContext context, ProtonBuffer challenge)
void	SaslAuthenticator.handleSaslOutcome(SaslClientContext context, SaslOutcome outcome, ProtonBuffer additional)

Uses of ProtonBuffer in org.apache.qpid.protonj2.engine.util

Methods in org.apache.qpid.protonj2.engine.util with parameters of type ProtonBuffer

Modifier and Type	Method	Description
static String	StringUtils.toQuotedString(ProtonBuffer buffer)	Converts the ProtonBuffer to a quoted string using a default max length before truncation value and appends a truncation indication if the string required truncation.
static String	StringUtils.toQuotedString(ProtonBuffer buffer, boolean appendIfTruncated)	Converts the ProtonBuffer to a quoted string using a default max length before truncation value.
static String	StringUtils.toQuotedString(ProtonBuffer buffer, int stringLength, boolean appendIfTruncated)	Converts the ProtonBuffer to a quoted string.

Uses of ProtonBuffer in org.apache.qpid.protonj2.types

Methods in org.apache.qpid.protonj2.types that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	Binary.asProtonBuffer()	Creates a read-only ProtonBuffer that contains a copy of the bytes wrapped by this Binary instance.
ProtonBuffer	DeliveryTag.ProtonDeliveryTag.tagBuffer()
ProtonBuffer	DeliveryTag.tagBuffer()	Returns a view of this DeliveryTag object as a ProtonBuffer.
ProtonBuffer	Symbol.toASCII()

Methods in org.apache.qpid.protonj2.types with parameters of type ProtonBuffer

Modifier and Type	Method	Description
static Symbol	Symbol.getSymbol(ProtonBuffer symbolBytes)	Look up a singleton Symbol instance that matches the given ProtonBuffer byte view of the Symbol.
static Symbol	Symbol.getSymbol(ProtonBuffer symbolBuffer, boolean copyOnCreate)	Look up a singleton Symbol instance that matches the given ProtonBuffer byte view of the Symbol.
void	DeliveryTag.ProtonDeliveryTag.writeTo(ProtonBuffer buffer)
void	DeliveryTag.writeTo(ProtonBuffer buffer)	Writes the tag as a sequence of bytes into the given buffer in the manner most efficient for the underlying DeliveryTag implementation.
void	Symbol.writeTo(ProtonBuffer target)	Writes the internal Symbol bytes to the provided ProtonBuffer.

Constructors in org.apache.qpid.protonj2.types with parameters of type ProtonBuffer

Modifier	Constructor	Description
	Binary(ProtonBuffer buffer)	Creates an Binary that wraps the given buffer or copies it if the given buffer is not read-only to preserves the immutable nature of this Binary instance.
	ProtonDeliveryTag(ProtonBuffer tagBytes)

Uses of ProtonBuffer in org.apache.qpid.protonj2.types.messaging

Methods in org.apache.qpid.protonj2.types.messaging that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	Data.getBuffer()	Returns the ProtonBuffer that contains the bytes carried in the Data section.

Methods in org.apache.qpid.protonj2.types.messaging with parameters of type ProtonBuffer

Modifier and Type	Method	Description
Data	Data.copyTo(ProtonBuffer target)	Copies the binary payload of this Data section info the given target buffer.

Constructors in org.apache.qpid.protonj2.types.messaging with parameters of type ProtonBuffer

Modifier	Constructor	Description
	Data(ProtonBuffer buffer)

Uses of ProtonBuffer in org.apache.qpid.protonj2.types.security

Methods in org.apache.qpid.protonj2.types.security that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	SaslOutcome.getAdditionalData()
ProtonBuffer	SaslChallenge.getChallenge()
ProtonBuffer	SaslInit.getInitialResponse()
ProtonBuffer	SaslResponse.getResponse()

Methods in org.apache.qpid.protonj2.types.security with parameters of type ProtonBuffer

Modifier and Type	Method	Description
SaslOutcome	SaslOutcome.setAdditionalData(ProtonBuffer additionalData)
SaslChallenge	SaslChallenge.setChallenge(ProtonBuffer challenge)
SaslInit	SaslInit.setInitialResponse(ProtonBuffer initialResponse)
SaslResponse	SaslResponse.setResponse(ProtonBuffer response)

Uses of ProtonBuffer in org.apache.qpid.protonj2.types.transport

Methods in org.apache.qpid.protonj2.types.transport that return ProtonBuffer

Modifier and Type	Method	Description
ProtonBuffer	AMQPHeader.getBuffer()

Methods in org.apache.qpid.protonj2.types.transport with parameters of type ProtonBuffer

Modifier and Type	Method	Description
default void	Performative.PerformativeHandler.handleAttach(Attach attach, ProtonBuffer payload, int channel, E context)
default void	Performative.PerformativeHandler.handleBegin(Begin begin, ProtonBuffer payload, int channel, E context)
default void	Performative.PerformativeHandler.handleClose(Close close, ProtonBuffer payload, int channel, E context)
default void	Performative.PerformativeHandler.handleDetach(Detach detach, ProtonBuffer payload, int channel, E context)
default void	Performative.PerformativeHandler.handleDisposition(Disposition disposition, ProtonBuffer payload, int channel, E context)
default void	Performative.PerformativeHandler.handleEnd(End end, ProtonBuffer payload, int channel, E context)
default void	Performative.PerformativeHandler.handleFlow(Flow flow, ProtonBuffer payload, int channel, E context)
default void	Performative.PerformativeHandler.handleOpen(Open open, ProtonBuffer payload, int channel, E context)
default void	Performative.PerformativeHandler.handleTransfer(Transfer transfer, ProtonBuffer payload, int channel, E context)
<E> void	Attach.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	Begin.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	Close.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	Detach.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	Disposition.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	End.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	Flow.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	Open.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	Performative.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
<E> void	Transfer.invoke(Performative.PerformativeHandler<E> handler, ProtonBuffer payload, int channel, E context)
Transfer	Transfer.setDeliveryTag(ProtonBuffer tagBytes)

Constructors in org.apache.qpid.protonj2.types.transport with parameters of type ProtonBuffer

Modifier	Constructor	Description
	AMQPHeader(ProtonBuffer buffer)
	AMQPHeader(ProtonBuffer buffer, boolean validate)