1 package demo.mtclient; 2 3 public class serverImpl 4 extends MyServerPOA 5 { 6 private static final int _delay = 245; 7 8 private void delay() 9 { 10 try 11 { 12 Thread.currentThread().sleep(_delay); 13 } 14 catch( InterruptedException i) 15 {} 16 } 17 18 public String [] arryfy( String s, int i ) 19 { 20 String result [] = new String [i]; 21 for( int j = 0; j < i; j++ ) 22 result[j] = s; 23 delay(); 24 return result; 25 } 26 27 public String writeMessage( String s ) 28 { 29 System.out.println("Message from " + s ); 30 delay(); 31 return s + " written"; 32 } 33 34 public String writeMessages( String [] s, Observer _observer ) 35 { 36 for( int i = 0; i < s.length; i++) 37 System.out.print("Message: " + s[i] + ", "); 38 39 delay(); 40 41 _observer.update1(_observer); 42 _observer.update2(); 43 return "ok."; 44 } 45 } 46 47 48 | Popular Tags |