package com.xcong.excoin.netty.common;
|
|
import io.netty.channel.Channel;
|
import io.netty.channel.group.ChannelGroup;
|
import io.netty.channel.group.DefaultChannelGroup;
|
import io.netty.util.concurrent.GlobalEventExecutor;
|
|
public class ClientChannelManager {
|
private static ChannelGroup SERVER_GROUP = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
|
|
public static ChannelGroup getServerGroup() {
|
return SERVER_GROUP;
|
}
|
|
public static void addServerGroup(Channel channel) {
|
SERVER_GROUP.add(channel);
|
}
|
|
public static void removeServerGroup(Channel channel) {
|
SERVER_GROUP.remove(channel);
|
}
|
|
}
|