Examples of addReceiver()


Examples of de.iritgo.aktario.core.network.ClientTransceiver.addReceiver()

      }
    }

    ClientTransceiver transceiver = new ClientTransceiver(AppContext.instance().getChannelNumber());

    transceiver.addReceiver(AppContext.instance().getChannelNumber());
    action.setTransceiver(transceiver);
    ActionTools.sendToServer(action);
  }

  /**
 
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

     *
     * @param localName The name of the node to set to busy
     */
    public void setNodeBusy(String localName) {
        ACLMessage message = new ACLMessage(ACLMessage.REFUSE);
        message.addReceiver(new AID(localName, false));
        message.setContent("busy");
        send(message);
    }

    /**
 
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

     * @param resource The destination resource
     */
    private void checkNodes(DFAgentDescription[] nodes, ACLMessage requestMessage, String resource) {
        ACLMessage checkMessage = new ACLMessage(ACLMessage.QUERY_IF);
        for (DFAgentDescription node : nodes) {
            checkMessage.addReceiver(node.getName());
        }

        send(checkMessage);
        addBehaviour(new NodeContactBehaviour(this, requestMessage, resource));
    }
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

                    "{0} is now busy.",
                    myAgent.getLocalName());
            currentMessage = message;

            ACLMessage requestMessage = new ACLMessage(ACLMessage.REQUEST);
            requestMessage.addReceiver(new AID(destinationLocalName, false));
            requestMessage.setContent(message.getContent());
            myAgent.send(requestMessage);
        }

        /**
 
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

     *
     * @param localName The name of the node to kill
     */
    public void killNode(String localName) {
        ACLMessage message = new ACLMessage(ACLMessage.CANCEL);
        message.addReceiver(new AID(localName, false));
        message.setContent("terminate");
        send(message);
    }

    /**
 
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

   @see #createSubscriptionMessage(Agent, AID, DFAgentDescription, SearchConstraints)
   @see #decodeNotification(String)
   */
  public static ACLMessage createCancelMessage(Agent a, AID dfName, ACLMessage subscribe) {
    ACLMessage cancel = new ACLMessage(ACLMessage.CANCEL);
    cancel.addReceiver(dfName);
    cancel.setLanguage(subscribe.getLanguage());
    cancel.setOntology(subscribe.getOntology());
    cancel.setProtocol(subscribe.getProtocol());
    cancel.setConversationId(subscribe.getConversationId());
    cancel.setContent(encodeCancel(dfName, subscribe));
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

    this.myAction = myAction;
  }
 
  protected ACLMessage prepareRequest(ACLMessage msg){
    ACLMessage request = new ACLMessage(ACLMessage.REQUEST);
    request.addReceiver(remoteDF);
    request.setOntology(FIPAManagementOntology.getInstance().getName());
    request.setLanguage(FIPANames.ContentLanguage.FIPA_SL0);
    request.setProtocol(FIPANames.InteractionProtocol.FIPA_REQUEST);
   
    Action act = new Action(remoteDF, myAction);
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

    return null;
  }

  private ACLMessage createAMSRequest() {
    ACLMessage request = new ACLMessage(ACLMessage.REQUEST);
    request.addReceiver(myAgent.getAMS());
    request.setProtocol(FIPANames.InteractionProtocol.FIPA_REQUEST);
    request.setLanguage(FIPANames.ContentLanguage.FIPA_SL);
    request.setOntology(JADEManagementOntology.getInstance().getName());
    return request;
  }
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

  ////////////////////////////////////////////
  // Private utility methods
  ////////////////////////////////////////////
  private ACLMessage createHelperRequest(AID helper) {
    ACLMessage request = new ACLMessage(ACLMessage.REQUEST);
    request.addReceiver(helper);
    request.setProtocol(FIPANames.InteractionProtocol.FIPA_REQUEST);
    request.setLanguage(FIPANames.ContentLanguage.FIPA_SL);
    request.setOntology(LogManagementOntology.getInstance().getName());
    return request;
  }
View Full Code Here

Examples of jade.lang.acl.ACLMessage.addReceiver()

  private void proceed(AID id) {
    String pendingReplyWith = (String) pendingReplies.remove(id);
    AID tn = (AID) notifiers.get(id);
    if (pendingReplyWith != null && tn != null) {
      ACLMessage msg = new ACLMessage(ACLMessage.INFORM);
      msg.addReceiver(tn);
      msg.setInReplyTo(pendingReplyWith);
      send(msg);
    }
  }
 
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.