public class ConfigServer
extends org.agilewiki.jasocket.server.Server
implements org.agilewiki.jasocket.serverNameListener.ServerNameListener
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
logger |
static String |
NAME_TIME_VALUE_TYPE |
static org.agilewiki.jid.collection.vlenc.map.StringBMapJidFactory |
nameTimeValueMapFactory |
Constructor and Description |
---|
ConfigServer() |
Modifier and Type | Method and Description |
---|---|
boolean |
assign(String name,
long timestamp,
String value) |
void |
close() |
String |
get(String name) |
static void |
main(String[] args) |
protected int |
maxSize() |
protected org.agilewiki.jfile.block.Block |
newDbBlock() |
protected String |
serverName() |
void |
serverNameAdded(String address,
String name) |
void |
serverNameRemoved(String address,
String name) |
protected void |
startServer(org.agilewiki.jasocket.jid.PrintJid out,
org.agilewiki.jactor.RP rp) |
boolean |
subscribe(ConfigListener listener) |
boolean |
unsubscribe(ConfigListener 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 NAME_TIME_VALUE_TYPE
public static final org.agilewiki.jid.collection.vlenc.map.StringBMapJidFactory nameTimeValueMapFactory
public static org.slf4j.Logger logger
public boolean subscribe(ConfigListener listener) throws Exception
Exception
public boolean unsubscribe(ConfigListener listener)
protected String serverName()
serverName
in class org.agilewiki.jasocket.server.Server
protected int maxSize()
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 boolean assign(String name, long timestamp, String value) throws Exception
Exception
public void close()
close
in interface org.agilewiki.jactor.Closable
close
in class org.agilewiki.jasocket.server.Server
protected org.agilewiki.jfile.block.Block newDbBlock()
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
Copyright © 2013. All Rights Reserved.