andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix compile error in test caused by 2d48ec4e3f

Browse Source
This commit is contained in:
Norman Maurer 2019-11-28 11:31:21 +01:00
parent 8cfd71c354
commit 0a252b48b1
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
transport-native-epoll/src/test/java/io/netty/channel/epoll/EpollDatagramScatteringReadTest.java
View File

@ -215,7 +215,7 @@ public class EpollDatagramScatteringReadTest extends AbstractDatagramTest {
try { try {
cb.handler(new SimpleChannelInboundHandler<Object>() { cb.handler(new SimpleChannelInboundHandler<Object>() {
@Override @Override
public void channelRead0(ChannelHandlerContext ctx, Object msgs) { public void messageReceived(ChannelHandlerContext ctx, Object msgs) {
// Nothing will be sent. // Nothing will be sent.
} }
}); });
@ -224,13 +224,13 @@ public class EpollDatagramScatteringReadTest extends AbstractDatagramTest {
final AtomicReference<Throwable> errorRef = new AtomicReference<Throwable>(); final AtomicReference<Throwable> errorRef = new AtomicReference<Throwable>();
final byte[] bytes = new byte[packetSize]; final byte[] bytes = new byte[packetSize];
PlatformDependent.threadLocalRandom().nextBytes(bytes); ThreadLocalRandom.current().nextBytes(bytes);
final CountDownLatch latch = new CountDownLatch(1); final CountDownLatch latch = new CountDownLatch(1);
sb.handler(new SimpleChannelInboundHandler<DatagramPacket>() { sb.handler(new SimpleChannelInboundHandler<DatagramPacket>() {
@Override @Override
protected void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg) { protected void messageReceived(ChannelHandlerContext ctx, DatagramPacket msg) {
assertEquals(ccAddress, msg.sender()); assertEquals(ccAddress, msg.sender());
assertEquals(bytes.length, msg.content().readableBytes()); assertEquals(bytes.length, msg.content().readableBytes());