diff --git a/transport/src/main/java/io/netty/channel/socket/aio/AioServerSocketChannel.java b/transport/src/main/java/io/netty/channel/socket/aio/AioServerSocketChannel.java index 2dea0b580c..efb016242d 100644 --- a/transport/src/main/java/io/netty/channel/socket/aio/AioServerSocketChannel.java +++ b/transport/src/main/java/io/netty/channel/socket/aio/AioServerSocketChannel.java @@ -18,6 +18,7 @@ package io.netty.channel.socket.aio; import io.netty.buffer.ChannelBufType; import io.netty.channel.ChannelException; import io.netty.channel.ChannelFuture; +import io.netty.channel.ChannelMetadata; import io.netty.channel.socket.ServerSocketChannel; import io.netty.logging.InternalLogger; import io.netty.logging.InternalLoggerFactory; @@ -31,6 +32,8 @@ import java.nio.channels.AsynchronousSocketChannel; public class AioServerSocketChannel extends AbstractAioChannel implements ServerSocketChannel { + private static final ChannelMetadata METADATA = new ChannelMetadata(ChannelBufType.MESSAGE, false); + private static final AcceptHandler ACCEPT_HANDLER = new AcceptHandler(); private static final InternalLogger logger = InternalLoggerFactory.getInstance(AioServerSocketChannel.class); @@ -61,8 +64,8 @@ public class AioServerSocketChannel extends AbstractAioChannel implements Server } @Override - public ChannelBufType bufferType() { - return ChannelBufType.MESSAGE; + public ChannelMetadata metadata() { + return METADATA; } @Override