protonj2/src/main/java/org/apache/qpid/protonj2/buffer/netty/Netty4ProtonBufferAllocator.java [110:130]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public ProtonCompositeBuffer composite() {
        checkClosed();
        return ProtonCompositeBuffer.create(this);
    }

    @Override
    public ProtonCompositeBuffer composite(ProtonBuffer buffer) {
        checkClosed();
        return ProtonCompositeBuffer.create(this, buffer);
    }

    @Override
    public ProtonCompositeBuffer composite(ProtonBuffer[] buffers) {
        checkClosed();
        return ProtonCompositeBuffer.create(this, buffers);
    }

    private void checkClosed() {
        if (closed) {
            throw new IllegalStateException("This allocator instance is closed");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



protonj2/src/main/java/org/apache/qpid/protonj2/buffer/netty/Netty5ProtonBufferAllocator.java [115:135]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    @Override
    public ProtonCompositeBuffer composite() {
        checkClosed();
        return ProtonCompositeBuffer.create(this);
    }

    @Override
    public ProtonCompositeBuffer composite(ProtonBuffer buffer) {
        checkClosed();
        return ProtonCompositeBuffer.create(this, buffer);
    }

    @Override
    public ProtonCompositeBuffer composite(ProtonBuffer[] buffers) {
        checkClosed();
        return ProtonCompositeBuffer.create(this, buffers);
    }

    private void checkClosed() {
        if (closed) {
            throw new IllegalStateException("This allocator instance is closed");
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -