cancel() | BulletinConsumer | [inline, private] |
getCluster() | BulletinConsumer | [inline, private] |
invoke(IEvent event, IPayload payload) | MessageConsumer | [inline] |
notify(IBuffer buffer) | BulletinConsumer | [inline, private] |
pauseGroup() | BulletinConsumer | [inline, private] |
resumeGroup() | BulletinConsumer | [inline, private] |
this(Cluster cluster, IEvent event) | MessageConsumer | [inline] |
SocketListener::this(ISocketReader reader, IBuffer buffer) | SocketListener | [inline, private] |