public class TucsonNodeService
extends java.lang.Object
Constructor and Description |
---|
TucsonNodeService() |
TucsonNodeService(int portno) |
TucsonNodeService(java.lang.String conf,
int portNumber,
Tuple persistTempl) |
Modifier and Type | Method and Description |
---|---|
void |
activateObservability() |
void |
addAgent(TucsonAgentId aid) |
void |
addInspectorAgent(InspectorContextSkel i) |
void |
addNodeAgent(java.lang.Thread t) |
void |
addTCAgent(TucsonAgentId agentId,
TucsonTupleCentreId tid) |
void |
deactivateObservability() |
boolean |
destroyCore(java.lang.String tcn) |
boolean |
disablePersistency(java.lang.String tc) |
void |
disablePersistency(Tuple template) |
boolean |
enablePersistency(java.lang.String tc) |
void |
enablePersistency(Tuple template) |
java.util.Map<java.lang.String,TucsonTCUsers> |
getCores() |
java.util.ArrayList<InspectorContextSkel> |
getInspectorAgents() |
java.util.Date |
getInstallationDate() |
NodeServiceListener |
getListener() |
int |
getTCPPort() |
static java.lang.String |
getVersion() |
void |
install() |
static boolean |
isInstalled(int timeout) |
static boolean |
isInstalled(int port,
int timeout) |
static boolean |
isInstalled(java.lang.String netid,
int port,
int timeout) |
static void |
main(java.lang.String[] args) |
void |
removeAgent(TucsonAgentId aid) |
void |
removeInspectorAgent(InspectorContextSkel i) |
void |
removeNodeAgent(java.lang.Thread t) |
TucsonTCUsers |
resolveCore(java.lang.String tcn) |
void |
shutdown() |
public TucsonNodeService()
public TucsonNodeService(int portno)
portno
- the default listening port of this TuCSoN nodepublic TucsonNodeService(java.lang.String conf, int portNumber, Tuple persistTempl)
conf
- the configuration file to loadportNumber
- the default listening port of this TuCSoN nodepersistTempl
- the persistency template to be used to permanently store
tuplespublic static java.lang.String getVersion()
public static boolean isInstalled(int timeout) throws DialogInitializationException, DialogCloseException
public static boolean isInstalled(int port, int timeout) throws DialogInitializationException, DialogCloseException
public static boolean isInstalled(java.lang.String netid, int port, int timeout) throws UnreachableNodeException, DialogInitializationException, DialogCloseException
netid
- the IP address where to test if a TuCSoN node is up and
runningport
- the listening port where to test if a TuCSoN node is up and
runningtimeout
- the maximum waiting time the caller agent can afford to wait
for a responseUnreachableNodeException
- if the given host is unknownDialogInitializationException
- if some network problems ariseDialogCloseException
- if some network problems arisepublic static void main(java.lang.String[] args)
args
- the arguments to start the TuCSoN node withpublic void activateObservability()
public void addAgent(TucsonAgentId aid)
aid
- the identifier of the agent to add to this TuCSoN nodepublic void addInspectorAgent(InspectorContextSkel i)
i
- the inspector agent to addpublic void addNodeAgent(java.lang.Thread t)
t
- the identifier of the internal management agent to add to this
TuCSoN nodepublic void addTCAgent(TucsonAgentId agentId, TucsonTupleCentreId tid)
agentId
- the identifier of the tuple centre agent to add to this TuCSoN
nodetid
- the identifier of the tuple centre whose agent has to be addedpublic void deactivateObservability()
public boolean destroyCore(java.lang.String tcn)
tcn
- the String representing the tuple centre identifier to destroypublic boolean disablePersistency(java.lang.String tc)
tc
- the identifier of the tuple centre whose persistency service
should be disabledpublic void disablePersistency(Tuple template)
template
- the tuple template to be used in filtering tuple centre
identifiers whose persistency service should be disabledpublic boolean enablePersistency(java.lang.String tc)
tc
- the identifier of the tuple centre whose persistency service
should be enabledpublic void enablePersistency(Tuple template)
template
- the tuple template to be used in filtering tuple centre
identifiers whose persistency service should be enabledpublic java.util.Map<java.lang.String,TucsonTCUsers> getCores()
public java.util.ArrayList<InspectorContextSkel> getInspectorAgents()
public java.util.Date getInstallationDate()
public NodeServiceListener getListener()
public int getTCPPort()
public void install()
public void removeAgent(TucsonAgentId aid)
aid
- the identifier of the TuCSoN agent to be removed from userspublic void removeInspectorAgent(InspectorContextSkel i)
i
- the InspectorContextSkel to eliminatepublic void removeNodeAgent(java.lang.Thread t)
t
- the Thread object executing the internal management agent to
be removedpublic TucsonTCUsers resolveCore(java.lang.String tcn)
tcn
- the String representation of the tuple centre whose usage
associations should be retrievedpublic void shutdown()