|
Magentix2
2.1.1
|
|
Magentix2
2.1.1
|
Public Member Functions | |
| int | getMinArgs () |
| int | getMaxArgs () |
| void | checkArguments (Term[] args) throws JasonException |
| Object | execute (TransitionSystem ts, Unifier un, Term[] args) throws Exception |
Package Attributes | |
| Jason_Fipa_Query_Initiator | fqi = null |
This class represents the internal action to be used when adding a conversation to a Jason agent under the Fipa Query If/Ref Protocol as initiator
Definition at line 25 of file ia_fipa_query_Initiator.java.
| void jason.stdlib.ia_fipa_query_Initiator.checkArguments | ( | Term[] | args | ) | throws JasonException |
Definition at line 39 of file ia_fipa_query_Initiator.java.
{
super.checkArguments(args);
boolean result = false;
if ( (((Term)args[args.length-1]).isAtom())||
(((Term)args[args.length-1]).isString())||
(((Term)args[args.length-1]).isLiteral())||
(((Term)args[args.length-1]).isNumeric())){result=true;}
result = (result && (((Term)args[0]).isString()) );
if ( protocolSteep.compareTo(Protocol_Template.START_STEP)==0)
{
int cont = 0;
for (Term t:args){
switch (cont){
case 1:result = ((result&&t.isAtom())||(result&&t.isString()));
break;
case 2:result = (result&&t.isNumeric());
break;
case 3:result = (result&&t.isString());
break;
case 4:result = (result&&t.isAtom());
break;
}
cont++;
}
}
if ( (protocolSteep.compareTo(Protocol_Template.QUERYIF_STEP)==0)||
(protocolSteep.compareTo(Protocol_Template.QUERYREF_STEP)==0))
{
int cont = 0;
for (Term t:args){
switch (cont){
case 1:result = (result&&t.isLiteral());
break;
case 2:result = ((result&&t.isAtom())||(result&&t.isString()));
break;
}
cont++;
}
}
if (protocolSteep.compareTo(Protocol_Template.INFORM_STEP)==0)
{
//result = (result && (((Term)args[2]).isAtom()) );
}
if (!result)
{
throw JasonException.createWrongArgument(this,"Parameters must be in correct format.");
}
}
| Object jason.stdlib.ia_fipa_query_Initiator.execute | ( | TransitionSystem | ts, |
| Unifier | un, | ||
| Term[] | args | ||
| ) | throws Exception |
Definition at line 97 of file ia_fipa_query_Initiator.java.
{
protocolSteep = getTermAsString(args[0]);
checkArguments(args);
agentConversationID = getTermAsString(args[args.length-1]);
if (((Term)args[args.length-1]).isString()){
agentConversationID = "\""+agentConversationID+"\"";
}
agName = ts.getUserAgArch().getAgName();
ConvJasonAgent myag = ((ConvMagentixAgArch)ts.getUserAgArch()).getJasonAgent();
if (ts.getSettings().verbose()>1)
ts.getAg().getLogger().info("CALLING INTERNAL ACTION WITH STEEP: '"+protocolSteep+"'"+" CID: "+agentConversationID);
/*
* When a FQ Protocol is taking place*/
if (protocolSteep.compareTo(Protocol_Template.START_STEP)==0){
String participant = getAtomAsString(args[1]);
timeOut = getTermAsInt(args[2]);
String initialInfo = getTermAsString(args[3]);
Literal perf = new LiteralImpl(getTermAsLiteral(args[4]));
//building message template
ACLMessage msg = new ACLMessage();
msg.setProtocol("fipa-query");
//int participantsNumber = participants.size();
if (perf.toString().compareTo("fqip")==0){
msg.setPerformative( ACLMessage.QUERY_IF);
}
if (perf.toString().compareTo("fqrp")==0){
msg.setPerformative( ACLMessage.QUERY_REF);
}
msg.setContent(initialInfo);
String factName = getFactoryName(agentConversationID,"FQ",true);
fqi = new Jason_Fipa_Query_Initiator(agName, ts);
String prevFactory = "";
if (Protocol_Factory!=null)
prevFactory = Protocol_Factory.getName();
if (prevFactory.compareTo(factName)!=0) // if it is a new conversation a create a new one. This verification is not strictly
//necessary because it supposed that this condition will be always truth. This must be improved but,
//as the participants can not distinguish between conversation of the same factory also one factory per conversation
//is created with the initiator factory name as a filter. This implies one factory per conversation in the initiator too
{ Protocol_Factory = fqi.newFactory(factName, null,
msg, 1, ((ConvMagentixAgArch)ts.getUserAgArch()).getJasonAgent(),timeOut);
((ConvMagentixAgArch)ts.getUserAgArch()).getJasonAgent().addFactoryAsInitiator(Protocol_Factory);
}
/* finally the new conversation starts an asynchronous conversation.*/
myag.lock();
String ConvID = myag.newConvID();
FQConversation conv = new FQConversation(agentConversationID,ConvID,participant,initialInfo,
((ConvMagentixAgArch)ts.getUserAgArch()).getJasonAgent().getAid(),factName);
ConvCProcessor processorTemplate = ((ConvCFactory)Protocol_Factory).cProcessorTemplate();
processorTemplate.setConversation(conv);
msg.setConversationId(ConvID);
ConvCProcessor convPprocessor = myag.newConversation(msg, processorTemplate, false, Protocol_Factory);
if (perf.toString().compareTo("fqip")==0){
conv.performative = ACLMessage.QUERY_IF;
}
if (perf.toString().compareTo("fqrp")==0){
conv.performative = ACLMessage.QUERY_REF;
}
convPprocessor.setConversation(conv);
myag.unlock();
conversationsList.put(agentConversationID, conv);
}else
if ((protocolSteep.compareTo(Protocol_Template.QUERYIF_STEP)==0)||
(protocolSteep.compareTo(Protocol_Template.QUERYREF_STEP)==0)){
((FQConversation)conversationsList.get(agentConversationID)).query = getTermAsLiteral(args[1]);
((FQConversation)conversationsList.get(agentConversationID)).Participant = getTermAsString(args[2]);
conversationsList.get(agentConversationID).release_semaphore();
}else
if(protocolSteep.compareTo(Protocol_Template.INFORM_STEP)==0){
conversationsList.get(agentConversationID).release_semaphore();
conversationsList.remove(agentConversationID);
}
return true;
}
Definition at line 36 of file ia_fipa_query_Initiator.java.
{ return 6; };
Definition at line 35 of file ia_fipa_query_Initiator.java.
{ return 2; };
Jason_Fipa_Query_Initiator jason.stdlib.ia_fipa_query_Initiator.fqi = null [package] |
Definition at line 33 of file ia_fipa_query_Initiator.java.
1.7.6.1