File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/test/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 38
38
import com .rabbitmq .stream .impl .TestUtils .DisabledIfFilteringNotSupported ;
39
39
import io .netty .buffer .ByteBuf ;
40
40
import io .netty .buffer .ByteBufAllocator ;
41
- import io .netty .buffer .UnpooledByteBufAllocator ;
41
+ import io .netty .buffer .PooledByteBufAllocator ;
42
42
import io .netty .channel .ChannelOption ;
43
43
import io .netty .channel .ConnectTimeoutException ;
44
44
import java .io .ByteArrayOutputStream ;
@@ -510,7 +510,7 @@ void consume() throws Exception {
510
510
@ ParameterizedTest
511
511
@ ValueSource (booleans = {true , false })
512
512
void publishAndConsume (boolean directBuffer ) throws Exception {
513
- ByteBufAllocator allocator = new UnpooledByteBufAllocator (directBuffer );
513
+ ByteBufAllocator allocator = new PooledByteBufAllocator (directBuffer );
514
514
int publishCount = 1_000_000 ;
515
515
516
516
CountDownLatch consumedLatch = new CountDownLatch (publishCount );
You can’t perform that action at this time.
0 commit comments