import com.mpush.api.protocol.Packet;
import com.mpush.tools.common.IOUtils;
import com.mpush.tools.common.Profiler;
import com.mpush.tools.config.CC;
import io.netty.channel.ChannelFutureListener;
<BUG>import java.net.InetSocketAddress;
import java.util.concurrent.atomic.AtomicInteger;</BUG>
public abstract class BaseMessage implements Message {
private static final AtomicInteger ID_SEQ = new AtomicInteger();
protected final Packet packet;

import com.mpush.api.protocol.Packet;
import com.mpush.tools.common.IOUtils;
import com.mpush.tools.common.Profiler;
import com.mpush.tools.config.CC;
import io.netty.channel.ChannelFutureListener;
import java.net.InetSocketAddress;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.atomic.AtomicInteger;
public abstract class BaseMessage implements Message {
private static final AtomicInteger ID_SEQ = new AtomicInteger();
protected final Packet packet;
