|
1 package org.objectweb.celtix.systest.stress.concurrency;
2
3
4 import java.util.logging.Level  ;
5 import java.util.logging.Logger ;
6
7 import javax.xml.ws.Endpoint;
8
9 import org.objectweb.celtix.systest.common.TestServerBase;
10 import static org.objectweb.celtix.systest.stress.concurrency.ConcurrentInvokerTest.EXPECTED_CALLS;
11
12 public class Server extends TestServerBase {
13
14 private GreeterImpl implementor;
15
16 protected void run() {
17 implementor = new GreeterImpl();
18 String address = "http://localhost:9009/SoapContext/SoapPort";
19 Endpoint.publish(address, implementor);
20 }
21
22 public static void main(String [] args) {
23 try {
24 Server s = new Server();
25 s.start();
26 } catch (Exception ex) {
27 ex.printStackTrace();
28 System.exit(-1);
29 } finally {
30 System.out.println("done!");
31 }
32 }
33
34
40 protected boolean verify(Logger log) {
41 boolean verified = implementor.greetMeCount.get() == EXPECTED_CALLS
42 && implementor.greetMeOneWayCount.get() == EXPECTED_CALLS
43 && implementor.sayHiCount.get() == EXPECTED_CALLS
44 && implementor.docLitFaultCount.get() == EXPECTED_CALLS;
45 if (!verified) {
46 warn(log, "greetMe", implementor.greetMeCount.get());
47 warn(log, "greetMeOneWay", implementor.greetMeOneWayCount.get());
48 warn(log, "sayHi", implementor.sayHiCount.get());
49 warn(log, "docLitFault", implementor.docLitFaultCount.get());
50 }
51 return verified;
52 }
53
54 private void warn(Logger log, String method, int received) {
55 log.log(Level.WARNING,
56 "{0} received {1} calls, expected {2}",
57 new Object [] {method, received, EXPECTED_CALLS});
58 }
59 }
60 |
Popular Tags |
Java API By Example, From Geeks To Geeks.