1 24 package perfs; 25 26 import javax.jms.*; 27 28 31 public class MsgListener implements MessageListener 32 { 33 private int max; 34 private java.io.FileWriter writer; 35 private int overall = 10; 36 private int counter = 0; 37 private double travelT = 0; 38 39 public MsgListener(int max) throws Exception 40 { 41 this.max = max; 42 writer = new java.io.FileWriter ("PerfsFile"); 43 } 44 45 public void onMessage(Message msg) 46 { 47 counter++; 48 try { 49 travelT = travelT + 50 (System.currentTimeMillis() - 51 msg.getLongProperty("time")) / 1000; 52 53 if (counter == 10) { 54 counter = 0; 55 System.out.println("Overall counter: " + overall); 56 writer.write("" + overall + " Mean travel time (s): " 57 + (travelT / 10) + " \n"); 58 59 61 62 travelT = 0; 63 overall = overall + 10; 64 65 if (overall == max + 10) { 66 writer.close(); 67 System.out.println("Writer closed"); 68 synchronized(this) { 69 this.notify(); 70 } 71 } 72 } 73 } 74 catch (Exception exc) {} 75 } 76 } 77 | Popular Tags |