import io.netty.channel.ChannelPipeline;
import io.netty.channel.WriteBufferWaterMark;
import io.netty.handler.traffic.GlobalChannelTrafficShapingHandler;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
<BUG>import java.util.concurrent.TimeUnit;
import static com.mpush.tools.config.CC.mp.net.traffic_shaping.connect_server.*;
import static com.mpush.tools.thread.ThreadNames.T_TRAFFIC_SHAPING;</BUG>
public final class ConnectionServer extends NettyTCPServer {
private static ConnectionServer I;

import io.netty.channel.ChannelPipeline;
import io.netty.channel.WriteBufferWaterMark;
import io.netty.handler.traffic.GlobalChannelTrafficShapingHandler;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import static com.mpush.tools.config.CC.mp.net.traffic_shaping.connect_server.*;
import static com.mpush.tools.config.CC.mp.net.write_buffer_water_mark.connect_server_high;
import static com.mpush.tools.config.CC.mp.net.write_buffer_water_mark.connect_server_low;
import static com.mpush.tools.thread.ThreadNames.T_TRAFFIC_SHAPING;
public final class ConnectionServer extends NettyTCPServer {
private static ConnectionServer I;
