类 ClusterPusher
- java.lang.Object
-
- xin.alum.aio.cluster.ClusterPusher
-
- 所有已实现的接口:
ClusterFactory
public abstract class ClusterPusher extends Object implements ClusterFactory
-
-
字段概要
字段 修饰符和类型 字段 说明 protected io.netty.util.internal.logging.InternalLoggerloggerprotected PriorityBlockingQueue<Pusher<Transportable>>queue-
从接口继承的字段 xin.alum.aio.groups.ClusterFactory
QUEUE_CAPACITY
-
-
构造器概要
构造器 构造器 说明 ClusterPusher()
-
-
-
字段详细资料
-
logger
protected final io.netty.util.internal.logging.InternalLogger logger
-
queue
protected PriorityBlockingQueue<Pusher<Transportable>> queue
-
-
方法详细资料
-
push
protected abstract <T> boolean push(String channel, T d)
-
pushQueue
protected abstract void pushQueue()
-
kick
public void kick(Session session)
- 指定者:
kick在接口中ClusterFactory
-
push
public void push(String recipient, Transportable data)
- 指定者:
push在接口中ClusterFactory
-
-