Package com.rabbitmq.client.impl.nio

Class DefaultByteBufferFactory

java.lang.Object

com.rabbitmq.client.impl.nio.DefaultByteBufferFactory

All Implemented Interfaces:

ByteBufferFactory

public class DefaultByteBufferFactory
extends java.lang.Object
implements ByteBufferFactory

Default ByteBufferFactory that creates heap-based ByteBuffers. This behavior can be changed by passing in a custom Function to the constructor.

Since:

5.5.0

See Also:

NioParams, ByteBufferFactory

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.function.Function<java.lang.Integer,java.nio.ByteBuffer>	allocator

Constructor Summary

Constructors

Constructor	Description
DefaultByteBufferFactory()
DefaultByteBufferFactory(java.util.function.Function<java.lang.Integer,java.nio.ByteBuffer> allocator)

Method Summary

Modifier and Type	Method	Description
protected java.nio.ByteBuffer	createEncryptedByteBuffer(NioContext nioContext)
java.nio.ByteBuffer	createEncryptedReadBuffer(NioContext nioContext)	Create the network read ByteBuffer.
java.nio.ByteBuffer	createEncryptedWriteBuffer(NioContext nioContext)	Create the network write ByteBuffer.
java.nio.ByteBuffer	createReadBuffer(NioContext nioContext)	Create the ByteBuffer that contains inbound frames.
java.nio.ByteBuffer	createWriteBuffer(NioContext nioContext)	Create the ByteBuffer that contains outbound frames.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

allocator

private final java.util.function.Function<java.lang.Integer,java.nio.ByteBuffer> allocator

Constructor Detail

DefaultByteBufferFactory

public DefaultByteBufferFactory(java.util.function.Function<java.lang.Integer,java.nio.ByteBuffer> allocator)

DefaultByteBufferFactory

public DefaultByteBufferFactory()

Method Detail

createReadBuffer

public java.nio.ByteBuffer createReadBuffer(NioContext nioContext)

Description copied from interface: ByteBufferFactory

Create the ByteBuffer that contains inbound frames. This buffer is the network buffer for plain connections. When using SSL/TLS, this buffer isn't directly connected to the network, the encrypted read buffer is.

Specified by:

createReadBuffer in interface ByteBufferFactory

Returns:

createWriteBuffer

public java.nio.ByteBuffer createWriteBuffer(NioContext nioContext)

Description copied from interface: ByteBufferFactory

Create the ByteBuffer that contains outbound frames. This buffer is the network buffer for plain connections. When using SSL/TLS, this buffer isn't directed connected to the network, the encrypted write buffer is.

Specified by:

createWriteBuffer in interface ByteBufferFactory

Returns:

createEncryptedReadBuffer

public java.nio.ByteBuffer createEncryptedReadBuffer(NioContext nioContext)

Description copied from interface: ByteBufferFactory

Create the network read ByteBuffer. This buffer contains encrypted frames read from the network. The SSLEngine decrypts frame and pass them over to the read buffer.

Specified by:

createEncryptedReadBuffer in interface ByteBufferFactory

Returns:

createEncryptedWriteBuffer

public java.nio.ByteBuffer createEncryptedWriteBuffer(NioContext nioContext)

Description copied from interface: ByteBufferFactory

Create the network write ByteBuffer. This buffer contains encrypted outbound frames. These frames come from the write buffer that sends them through the SSLContext for encryption to this buffer.

Specified by:

createEncryptedWriteBuffer in interface ByteBufferFactory

Returns:

createEncryptedByteBuffer

protected java.nio.ByteBuffer createEncryptedByteBuffer(NioContext nioContext)