public class QuorumServer extends org.agilewiki.jasocket.server.Server implements org.agilewiki.jasocket.serverNameListener.ServerNameListener, ConfigListener
Modifier and Type | Field and Description |
---|---|
protected ConfigServer |
configServer |
static org.slf4j.Logger |
logger |
static String |
TOTAL_HOST_COUNT |
Constructor and Description |
---|
QuorumServer() |
Modifier and Type | Method and Description |
---|---|
void |
assigned(String name,
String value) |
void |
close() |
static void |
main(String[] args) |
protected String |
quorumServerName() |
protected String |
serverName() |
void |
serverNameAdded(String address,
String name) |
void |
serverNameRemoved(String address,
String name) |
void |
setQuorum(boolean quorum) |
protected void |
startServer(org.agilewiki.jasocket.jid.PrintJid out,
org.agilewiki.jactor.RP rp) |
void |
startupServer(StartupEntry startupEntry) |
boolean |
subscribe(QuorumListener listener) |
boolean |
unsubscribe(QuorumListener listener) |
agentChannelManager, evalServerCommand, getOperatorName, node, registerHelpCommand, registerServerCommand, registerShutdownCommand, startup, startupArgs
acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity
public static final String TOTAL_HOST_COUNT
public static org.slf4j.Logger logger
protected ConfigServer configServer
protected String quorumServerName()
protected String serverName()
serverName
in class org.agilewiki.jasocket.server.Server
protected void startServer(org.agilewiki.jasocket.jid.PrintJid out, org.agilewiki.jactor.RP rp) throws Exception
startServer
in class org.agilewiki.jasocket.server.Server
Exception
public void close()
close
in interface org.agilewiki.jactor.Closable
close
in class org.agilewiki.jasocket.server.Server
public void assigned(String name, String value) throws Exception
assigned
in interface ConfigListener
Exception
public boolean subscribe(QuorumListener listener) throws Exception
Exception
public boolean unsubscribe(QuorumListener listener)
public void serverNameAdded(String address, String name) throws Exception
serverNameAdded
in interface org.agilewiki.jasocket.serverNameListener.ServerNameListener
Exception
public void serverNameRemoved(String address, String name) throws Exception
serverNameRemoved
in interface org.agilewiki.jasocket.serverNameListener.ServerNameListener
Exception
public void startupServer(StartupEntry startupEntry) throws Exception
Exception
Copyright © 2013. All Rights Reserved.