Fixing compile error, introduce by 4b41ae73f3
This commit is contained in:
parent
4b41ae73f3
commit
6d86856e40
@ -157,7 +157,7 @@ public class FixedChannelPoolTest {
|
|||||||
*/
|
*/
|
||||||
@Test
|
@Test
|
||||||
public void testAcquireNewConnectionWhen() throws Exception {
|
public void testAcquireNewConnectionWhen() throws Exception {
|
||||||
EventLoopGroup group = new DefaultEventLoopGroup();
|
EventLoopGroup group = new LocalEventLoopGroup();
|
||||||
LocalAddress addr = new LocalAddress(LOCAL_ADDR_ID);
|
LocalAddress addr = new LocalAddress(LOCAL_ADDR_ID);
|
||||||
Bootstrap cb = new Bootstrap();
|
Bootstrap cb = new Bootstrap();
|
||||||
cb.remoteAddress(addr);
|
cb.remoteAddress(addr);
|
||||||
@ -170,7 +170,7 @@ public class FixedChannelPoolTest {
|
|||||||
.childHandler(new ChannelInitializer<LocalChannel>() {
|
.childHandler(new ChannelInitializer<LocalChannel>() {
|
||||||
@Override
|
@Override
|
||||||
public void initChannel(LocalChannel ch) throws Exception {
|
public void initChannel(LocalChannel ch) throws Exception {
|
||||||
ch.pipeline().addLast(new ChannelHandlerAdapter());
|
ch.pipeline().addLast(new ChannelInboundHandlerAdapter());
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user