broadcast(IChannel channel, IPayload payload=null) | Cluster | [inline] |
createChannel(char[] channel) | Cluster | [inline] |
createConsumer(IChannel channel, IEvent.Style style, IEventListener notify) | Cluster | [inline] |
getCache(IChannel channel, char[] key, bool remove) | Cluster | [inline] |
getGroup(char[] channel) | Cluster | [inline] |
getLogger() | Cluster | [inline] |
getQueue(IChannel channel) | Cluster | [inline] |
groupPort | Cluster | [private] |
groupPrefix | Cluster | [private] |
groups | Cluster | [private, static] |
groupTTL | Cluster | [private] |
loadCache(IChannel channel, char[] key, IPayload payload) | Cluster | [inline] |
logger | Cluster | [private] |
mBuffer | Cluster | [private] |
mSocket | Cluster | [private] |
mWriter | Cluster | [private] |
nodeSet | Cluster | [private] |
notify(IEvent event, IPayload payload) | Cluster | [inline] |
putCache(IChannel channel, char[] key, IPayload payload) | Cluster | [inline] |
putQueue(IChannel channel, IPayload payload) | Cluster | [inline] |
this() | Cluster | [inline, static] |
this(ILogger logger=null) | Cluster | [inline] |
this(ILogger logger, IConduit conduit) | Cluster | [inline] |
this(ILogger logger, uint serverPort) | Cluster | [inline] |