Skip to content

Commit 2a3194b

Browse files
authored
Merge pull request #793 from rabbitmq/adaptative-allocator
Use Netty 4.2 adaptative byte buffer allocator by default
2 parents 43cede9 + c43bcad commit 2a3194b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/com/rabbitmq/stream/impl/Utils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import com.rabbitmq.stream.*;
2121
import com.rabbitmq.stream.impl.Client.ClientParameters;
2222
import io.netty.buffer.ByteBufAllocator;
23-
import io.netty.buffer.PooledByteBufAllocator;
2423
import io.netty.channel.ConnectTimeoutException;
2524
import io.netty.channel.EventLoopGroup;
2625
import io.netty.channel.MultiThreadIoEventLoopGroup;
@@ -434,7 +433,8 @@ static EventLoopGroup eventLoopGroup() {
434433
}
435434

436435
static ByteBufAllocator byteBufAllocator() {
437-
return PooledByteBufAllocator.DEFAULT;
436+
return ByteBufAllocator.DEFAULT;
437+
// return PooledByteBufAllocator.DEFAULT;
438438
}
439439

440440
/*

0 commit comments

Comments
 (0)