buffer | BulletinConsumer | [private] |
cancel() | BulletinConsumer | [inline] |
cluster | BulletinConsumer | [private] |
consumer | BulletinConsumer | [private] |
event | BulletinConsumer | [private] |
getCluster() | BulletinConsumer | [inline] |
invoke(IEvent event, IPayload payload) | BulletinConsumer | [inline, protected] |
msg | SocketListener | [private] |
notify(IBuffer buffer) | BulletinConsumer | [inline] |
pauseGroup() | BulletinConsumer | [inline] |
reader | BulletinConsumer | [private] |
resumeGroup() | BulletinConsumer | [inline] |
run() | SocketListener | [inline, private] |
setErrorLimit(ushort limit) | SocketListener | [inline, private] |
start() | SocketListener | [inline, private] |
this(Cluster cluster, IEvent event) | BulletinConsumer | [inline] |
SocketListener::this(ISocketReader reader, IBuffer buffer) | SocketListener | [inline, private] |