Examples of GenericMessage


Examples of rlVizLib.messaging.GenericMessage

public class EnvShellUnLoadResponse extends AbstractResponse{
  public EnvShellUnLoadResponse(){}

//  Constructor when the benchmark is interpreting the returned response
  public EnvShellUnLoadResponse(String theMessage) throws NotAnRLVizMessageException {
    GenericMessage theGenericResponse=new GenericMessage(theMessage);
  }
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage

  }
 

  public EnvVersionSupportedResponse(String responseMessage) throws NotAnRLVizMessageException {
            try{
    GenericMessage theGenericResponse = new GenericMessage(responseMessage);

   
    String thePayLoadString=theGenericResponse.getPayload();

    StringTokenizer versionTokenizer = new StringTokenizer(thePayLoadString, ":");

    theVersion=new RLVizVersion(versionTokenizer.nextToken());
             }catch(Exception e){
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage




  public AgentValueForObsResponse(String responseMessage) throws NotAnRLVizMessageException {
    GenericMessage theGenericResponse = new GenericMessage(responseMessage);

    String thePayLoadString=theGenericResponse.getPayload();

    StringTokenizer valueTokenizer = new StringTokenizer(thePayLoadString, ":");
    theValues = new Vector<Double>();
    String numValuesToken=valueTokenizer.nextToken();
    int numValues=Integer.parseInt(numValuesToken);
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage

import rlVizLib.messaging.GenericMessageParser;
import rlVizLib.messaging.NotAnRLVizMessageException;

public class AgentMessageParser extends GenericMessageParser{
  public static AgentMessages parseMessage(String theMessage) throws NotAnRLVizMessageException{
    GenericMessage theGenericMessage = new GenericMessage(theMessage);

    int cmdId=theGenericMessage.getTheMessageType();

    if(cmdId==AgentMessageType.kAgentQueryValuesForObs.id())return new AgentValueForObsRequest(theGenericMessage);
    if(cmdId==AgentMessageType.kAgentQueryVisualizerName.id())return new AgentVisualizerNameRequest(theGenericMessage);
    if(cmdId==AgentMessageType.kAgentQuerySupportedVersion.id())return new AgentVersionSupportedRequest(theGenericMessage);
    if(cmdId==AgentMessageType.kAgentGetGraphic.id())return new AgentGraphicRequest(theGenericMessage);
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage

    this.theResult=theResult;
  }

//  Constructor when the benchmark is interpreting the returned response
  public EnvShellRefreshResponse(String theMessage) throws NotAnRLVizMessageException {
    GenericMessage theGenericResponse=new GenericMessage(theMessage);

    String thePayLoadString=theGenericResponse.getPayload();

    StringTokenizer obsTokenizer = new StringTokenizer(thePayLoadString, ":");

                String loadResult=obsTokenizer.nextToken();
    String loadMessage=obsTokenizer.nextToken();
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage

import rlVizLib.messaging.GenericMessageParser;
import rlVizLib.messaging.NotAnRLVizMessageException;

public class EnvironmentMessageParser extends GenericMessageParser{
  public static EnvironmentMessages parseMessage(String theMessage) throws NotAnRLVizMessageException{
    GenericMessage theGenericMessage=new GenericMessage(theMessage);

    int cmdId=theGenericMessage.getTheMessageType();

    if(cmdId==EnvMessageType.kEnvQueryVarRanges.id())         return new EnvRangeRequest(theGenericMessage);
    if(cmdId==EnvMessageType.kEnvQueryObservationsForState.id())   return new EnvObsForStateRequest(theGenericMessage);
    if(cmdId==EnvMessageType.kEnvQuerySupportedVersion.id())   return new EnvVersionSupportedRequest(theGenericMessage);
    if(cmdId==EnvMessageType.kEnvReceiveRunTimeParameters.id())   return new EnvReceiveRunTimeParametersRequest(theGenericMessage);
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage

        }

        public Response(String responseMessage) throws NotAnRLVizMessageException {
            try {
                GenericMessage theGenericResponse = new GenericMessage(responseMessage);
                String payLoad = theGenericResponse.getPayLoad();
                DataInputStream DIS = BinaryPayload.getInputStreamFromPayload(payLoad);
                theImage = ImageIO.read(DIS);
            } catch (IOException ex) {
                Logger.getLogger(AgentGraphicRequest.class.getName()).log(Level.SEVERE, null, ex);
            }
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage

public class AgentShellListResponse extends AbstractResponse{
  private Vector<String> theAgentList = new Vector<String>();
  private Vector<ParameterHolder> theParamList = new Vector<ParameterHolder>();

  public AgentShellListResponse(String responseMessage) throws NotAnRLVizMessageException {
    GenericMessage theGenericResponse=new GenericMessage(responseMessage);

    String thePayLoadString=theGenericResponse.getPayload();

    StringTokenizer agentListTokenizer = new StringTokenizer(thePayLoadString, ":");

    String numAgentsToken=agentListTokenizer.nextToken();
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage

    this.theObservations=theObservations;
  }

 
  public EnvObsForStateResponse(String responseMessage) throws NotAnRLVizMessageException {
    GenericMessage theGenericResponse = new GenericMessage(responseMessage);

    String thePayLoadString=theGenericResponse.getPayload();

    StringTokenizer obsTokenizer = new StringTokenizer(thePayLoadString, ":");

    theObservations = new Vector<Observation>();
    String numValuesToken=obsTokenizer.nextToken();
View Full Code Here

Examples of rlVizLib.messaging.GenericMessage

        return theTaskSpecPayload;
    }

//  Constructor when the benchmark is interpreting the returned response
    public EnvShellTaskSpecResponse(String theMessage) throws NotAnRLVizMessageException {
        GenericMessage theGenericResponse = new GenericMessage(theMessage);

        String thePayLoadString = theGenericResponse.getPayload();
        DataInputStream DIS=BinaryPayload.getInputStreamFromPayload(thePayLoadString);
        theTaskSpecPayload=new TaskSpecPayload(DIS);
    }
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.