public class PsNodeAgent extends jade.core.Agent implements PsConstants, com.dpsframework.core.behaviour.BhConstants
PsConstants.AgentINSTANCE, PsConstants.BoardPKEYS, PsConstants.FwARTIFACTS, PsConstants.FwCLASS, PsConstants.FwDISTRIBUTION, PsConstants.FwPATHS, PsConstants.FwPKEYS, PsConstants.JADEdefaults, PsConstants.KwBASED, PsConstants.NodePKEYS, PsConstants.ToolPARAMETERS
Modifier and Type | Field and Description |
---|---|
private jade.content.lang.Codec |
codec |
private java.lang.Integer |
counter |
private bsh.Interpreter |
interpreterBSh |
private static jade.util.Logger |
logger |
private jade.util.leap.HashMap |
myBOB |
private RBEngine |
myEngine |
private PsNodeAgentGui |
myGui |
private PsNodeSettings |
myNode |
private static long |
serialVersionUID |
private java.lang.ThreadGroup |
thFWGroup |
private jade.core.behaviours.ThreadedBehaviourFactory |
threadBhv |
AP_ACTIVE, AP_DELETED, AP_IDLE, AP_INITIATED, AP_MAX, AP_MIN, AP_SUSPENDED, AP_WAITING, D_ACTIVE, D_MAX, D_MIN, D_RETIRED, D_SUSPENDED, D_UNKNOWN, MSG_QUEUE_CLASS
ACTION_ADVERTISE_NAME, ACTION_PROBLEMFOR_NAME, ACTION_PROCESS_NAME, ACTION_REPL_NAME, CAPTOR_MT, DEFAULT_FILE_WMDUMP_NAME, E2AA_MT, E2AS_MT, GGCC_MT, H2NI_MT, HOOK_CONVERSATION_ID_TYPE_BASAL, HOOK_CONVERSATION_ID_TYPE_MIGRATION, HOOK_CONVERSATION_TO_ASYNC, HOOK_CONVERSATION_TO_ENGINE, HOOK_CONVERSATION_TO_TICKETBOARD, HOOK_CONVERSTAION_ID_SHOWGUI, HOOK_CONVERSTAION_ID_TYPE_AGENDA, JAMO_MT, N2HR_MT, N2NRESPONDER_MT, NMIG_MT, PS_LOGGER_ENGINE_TEMPLATE, PS_USER_PROPERTY_ACTION, PS_USER_PROPERTY_CONVERSATION_ID, PS_USER_PROPERTY_FRAMEWORKNAME, PS_USER_PROPERTY_HAP, PS_USER_PROPERTY_PREDICATE, PS_USER_PROPERTY_PSDATE_INIT, PS_USER_PROPERTY_PSOUT_CLASS, PS_USER_PROPERTY_PSOUT_VALUE, PS_USER_PROPERTY_PSSCODE, PS_USER_PROPERTY_PSSTREV, PS_USER_PROPERTY_PSSVALUE, PS_USER_PROPERTY_PSTIME_END, PS_USER_PROPERTY_PSTIME_INIT, PS_USER_PROPERTY_RECEIVER, PS_USER_PROPERTY_SENDER, PS_USER_PROPERTY_ZIPFILENAME, STATE_A_MESSAGE, STATE_B_LAST_RESPONSE, STATE_B_MESSAGE, STATE_C_MESSAGE
Constructor and Description |
---|
PsNodeAgent() |
Modifier and Type | Method and Description |
---|---|
void |
doDelete() |
jade.core.AID |
getEngineAID()
Make an AID object with Internal but not real, agent-Engine-identifier.
|
private void |
goesTo_Level(int executionLevel) |
static void |
main(java.lang.String[] args) |
jade.lang.acl.ACLMessage |
makeProcessMessage() |
jade.lang.acl.ACLMessage |
makeProcessMessage(int iCode,
java.lang.String sValue) |
jade.lang.acl.ACLMessage |
makeProcessMessage(java.lang.String sCode,
java.lang.String sValue) |
jade.lang.acl.ACLMessage |
makeProcessMessage(java.lang.String receiverLocalName,
java.lang.String sCode,
java.lang.String sValue) |
jade.lang.acl.ACLMessage |
makeProcessMessage(java.lang.String receiverLocalName,
java.lang.String sCode,
java.lang.String sValue,
java.lang.StringBuilder commandToEval)
Usual methods for making Engine Messages.
|
jade.lang.acl.ACLMessage |
makeReplMessage() |
jade.lang.acl.ACLMessage |
makeReplMessage(java.lang.String commandToEval) |
jade.lang.acl.ACLMessage |
makeReplMessage(java.lang.String receiverLocalName,
java.lang.String commandToEval) |
jade.lang.acl.ACLMessage |
makeReplMessage(java.lang.String receiverLocalName,
java.lang.StringBuilder commandToEval) |
void |
migrateNodeAction(com.dpsframework.domain.Migrate mg,
jade.lang.acl.ACLMessage propose)
Serve Migrate Action to Problem-Solvers Ontology.
|
jade.util.leap.HashMap |
myBOB() |
RBEngine |
myEngine() |
PsNodeAgentGui |
myGui() |
PsNodeSettings |
myNode() |
private void |
outLogger(boolean verbose,
java.lang.Object[] o) |
private void |
outLogger(java.lang.Object[] o) |
private void |
outLogger(java.lang.String s) |
boolean |
requestMigrate(java.lang.String anfitrion)
Method to trigger Behaviour for packaging and sending Migration-PROPOSE message (`miab`: Message In A Bottle).
|
boolean |
requestShowGui(java.lang.String nodeName)
Method to trigger Behaviour for showing GUI of Nodes.
|
java.lang.Object[] |
searchDFServices() |
void |
selectTicketBoard(java.lang.String s) |
protected void |
setup() |
void |
showGuiAction(jade.domain.JADEAgentManagement.ShowGui sg,
jade.core.AID requester)
Serve the ShowGui action of the JADE management ontology.
|
jade.core.behaviours.ThreadedBehaviourFactory |
threadBhv() |
addBehaviour, afterClone, afterMove, beforeClone, beforeMove, blockingReceive, blockingReceive, blockingReceive, blockingReceive, changeStateTo, clean, createMessageQueue, doActivate, doClone, doMove, doSuspend, doTimeOut, doWait, doWait, doWake, getAgentState, getAID, getAID, getAMS, getArguments, getBootProperties, getContainerController, getContentManager, getCurQueueSize, getDefaultDF, getHap, getHelper, getLocalName, getName, getO2AInterface, getO2AObject, getProperty, getQueueSize, getState, here, isAlive, isRestarting, join, notifyChangeBehaviourState, notifyRestarted, postMessage, putBack, putO2AObject, receive, receive, registerO2AInterface, removeBehaviour, removeTimer, restartLater, restore, restoreBufferedState, run, send, setArguments, setEnabledO2ACommunication, setGenerateBehaviourEvents, setO2AManager, setQueueSize, takeDown, waitUntilStarted, write
private static final long serialVersionUID
private bsh.Interpreter interpreterBSh
private jade.content.lang.Codec codec
private PsNodeSettings myNode
private jade.util.leap.HashMap myBOB
private RBEngine myEngine
private jade.core.behaviours.ThreadedBehaviourFactory threadBhv
private PsNodeAgentGui myGui
private java.lang.ThreadGroup thFWGroup
private java.lang.Integer counter
private static jade.util.Logger logger
public PsNodeSettings myNode()
public jade.util.leap.HashMap myBOB()
public RBEngine myEngine()
public jade.core.behaviours.ThreadedBehaviourFactory threadBhv()
public PsNodeAgentGui myGui()
public void doDelete()
doDelete
in class jade.core.Agent
protected void setup()
setup
in class jade.core.Agent
private void goesTo_Level(int executionLevel)
public void showGuiAction(jade.domain.JADEAgentManagement.ShowGui sg, jade.core.AID requester) throws jade.domain.FIPAAgentManagement.FailureException
sg
- showGui method.requester
- agent requesterjade.domain.FIPAAgentManagement.FailureException
- If the GUI is already visible or some error occurs creating the GUI.public boolean requestMigrate(java.lang.String anfitrion)
anfitrion
- is the name of MonitorNNode which can help in migration process.public boolean requestShowGui(java.lang.String nodeName)
nodeName
- is the name of node to show again.public void migrateNodeAction(com.dpsframework.domain.Migrate mg, jade.lang.acl.ACLMessage propose)
---------------- Example: ---------------- (ACCEPT-PROPOSAL :sender ( agent-identifier :name Agent@127.0.0.1:1099/JADE :addresses (sequence http://PEGASUS:7778/acc )) :receiver (set ( agent-identifier :name Stage@127.0.0.1:1099/JADE :addresses (sequence http://PEGASUS:7778/acc )) ) :content "((done (migrate :app bin :args CLIPS :clazz com.dpsframework.util.PsStageNode :container Container-4 :node Stage)))" :reply-with Stage@127.0.0.1:1099/JADE1492786417822 :language fipa-sl0 :ontology Problem-Solvers :conversation-id Basal_Migration )
mg
- Action migrate sent by NodeRequester.propose
- Message complete received by MonitorAgent.public void selectTicketBoard(java.lang.String s)
public jade.lang.acl.ACLMessage makeProcessMessage(java.lang.String receiverLocalName, java.lang.String sCode, java.lang.String sValue, java.lang.StringBuilder commandToEval)
receiverLocalName
- Local Name of receiver.sCode
- See Interface RBEngine StringssValue
- String of sentencescommandToEval
- Lines of commands to evaluate.public jade.lang.acl.ACLMessage makeProcessMessage(java.lang.String receiverLocalName, java.lang.String sCode, java.lang.String sValue)
public jade.lang.acl.ACLMessage makeProcessMessage(java.lang.String sCode, java.lang.String sValue)
public jade.lang.acl.ACLMessage makeProcessMessage(int iCode, java.lang.String sValue)
public jade.lang.acl.ACLMessage makeProcessMessage()
public jade.core.AID getEngineAID()
public java.lang.Object[] searchDFServices()
public jade.lang.acl.ACLMessage makeReplMessage(java.lang.String receiverLocalName, java.lang.StringBuilder commandToEval)
receiverLocalName
- Receiver Agent LocalNamecommandToEval
- Lines of commands to evaluate.public jade.lang.acl.ACLMessage makeReplMessage(java.lang.String receiverLocalName, java.lang.String commandToEval)
public jade.lang.acl.ACLMessage makeReplMessage(java.lang.String commandToEval)
public jade.lang.acl.ACLMessage makeReplMessage()
private void outLogger(java.lang.Object[] o)
private void outLogger(boolean verbose, java.lang.Object[] o)
private void outLogger(java.lang.String s)
public static void main(java.lang.String[] args)