Robust/src/Benchmarks/mlp/directto/mlp-java/MessageList.java

   1 //import java.io.*;
   2 //import java.util.*;
   3
   4 public class MessageList {
   5   private Vector messages;
   6
   7   public MessageList() {
   8     messages=new Vector();
   9   }
  10
  11   public Message data() {
  12     Message m = (Message) messages.elementAt(0);
  13     messages.removeElementAt(0);
  14     return m;
  15   }
  16
  17   public Message next() {
  18     return data();
  19   }
  20
  21   public boolean hasNext() {
  22     return messages.size() != 0;
  23   }
  24
  25   //is true for DO_WORK
  26   public boolean setMessage(String line) {
  27     if (line.equals(""))
  28       return false;
  29
  30     System.out.println("I'm reading line "+line);
  31
  32     // treating comments
  33     if ((line.charAt(0)=='/')&&(line.charAt(1)=='/'))
  34       return false;
  35
  36     StringTokenizer st=new StringTokenizer(line);
  37     int time=Integer.parseInt(st.nextToken());
  38     String type=st.nextToken();
  39     Message newMessage=disjoint msgs new Message(time,type,st);
  40     messages.addElement(newMessage);
  41     if (type.equals("DO_WORK"))
  42       return true;
  43
  44     return false;
  45   }
  46
  47   public void executeAll(D2 d2) {
  48     System.out.println("executeAll: we have "+messages.size()+" messages.");
  49     while(hasNext())
  50       next().executeMessage(d2);
  51
  52     d2.getStatic().printInfo();
  53     d2.getFixList().printInfo();
  54     d2.getAircraftList().printInfo();
  55     d2.getFlightList().printInfo();
  56     System.out.println("Messages executed\n\n\n\n\n");
  57   }
  58 }