1 24 package perfs; 25 26 import javax.jms.*; 27 28 31 public class TopicMsgListener implements MessageListener 32 { 33 private int max; 34 private java.io.FileWriter writer; 35 private int overall = 50; 36 private int counter = 0; 37 private double travelT = 0; 38 39 public TopicMsgListener(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"); 52 53 if (counter == 50) { 54 counter = 0; 55 System.out.println("Overall counter: " + overall); 56 writer.write("" + overall + " Mean travel time (ms): " 57 + (travelT / 50) + " \n"); 58 59 61 travelT = 0; 62 overall = overall + 50; 63 64 if (overall == max + 50) { 65 writer.close(); 66 System.out.println("Writer closed"); 67 synchronized(this) { 68 this.notify(); 69 } 70 } 71 } 72 } 73 catch (Exception exc) {} 74 } 75 } 76 | Popular Tags |