com.rabbitmq.client.impl.nio

Class DefaultByteBufferFactory

java.lang.Object

com.rabbitmq.client.impl.nio.DefaultByteBufferFactory

All Implemented Interfaces:

ByteBufferFactory

public class DefaultByteBufferFactory
extends 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

Constructor Summary

Constructors

Constructor and Description
DefaultByteBufferFactory()
DefaultByteBufferFactory(Function<Integer,ByteBuffer> allocator)

Method Summary

Modifier and Type	Method and Description
protected ByteBuffer	createEncryptedByteBuffer(NioContext nioContext)
ByteBuffer	createEncryptedReadBuffer(NioContext nioContext) Create the network read ByteBuffer.
ByteBuffer	createEncryptedWriteBuffer(NioContext nioContext) Create the network write ByteBuffer.
ByteBuffer	createReadBuffer(NioContext nioContext) Create the ByteBuffer that contains inbound frames.
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

Constructor Detail

DefaultByteBufferFactory

public DefaultByteBufferFactory(Function<Integer,ByteBuffer> allocator)

DefaultByteBufferFactory

public DefaultByteBufferFactory()

Method Detail

createReadBuffer

public 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 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 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 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 ByteBuffer createEncryptedByteBuffer(NioContext nioContext)