diff --git a/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/ProtocolBootstrap.java b/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/ProtocolBootstrap.java index 6a8ffd6..55c894e 100644 --- a/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/ProtocolBootstrap.java +++ b/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/ProtocolBootstrap.java @@ -70,7 +70,7 @@ public abstract class ProtocolBootstrap implements HealthIndicator { if (tcpCfg != null) { - listener = new TcpListener<>(protocolName, tcpCfg, messageProcessor(), protocolContext.getStatsFactory()); + listener = new TcpListener(protocolName, tcpCfg, messageProcessor(), protocolContext.getStatsFactory()); } _init(); diff --git a/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpListener.java b/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpListener.java index 8f99074..121e295 100644 --- a/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpListener.java +++ b/jcpp-protocol-api/src/main/java/sanbing/jcpp/protocol/listener/tcp/TcpListener.java @@ -29,7 +29,7 @@ import sanbing.jcpp.protocol.listener.Listener; * @author baigod */ @Slf4j -public class TcpListener extends Listener { +public class TcpListener extends Listener { private Channel serverChannel; private EventLoopGroup bossGroup;