001: package org.objectweb.celtix.systest.stress.concurrency;
002:
003: import java.util.concurrent.Future;
004: import java.util.concurrent.atomic.AtomicInteger;
005:
006: import javax.jws.WebService;
007: import javax.xml.ws.AsyncHandler;
008: import javax.xml.ws.Response;
009:
010: import org.objectweb.hello_world_soap_http.BadRecordLitFault;
011: import org.objectweb.hello_world_soap_http.Greeter;
012: import org.objectweb.hello_world_soap_http.NoSuchCodeLitFault;
013: import org.objectweb.hello_world_soap_http.types.BareDocumentResponse;
014: import org.objectweb.hello_world_soap_http.types.ErrorCode;
015: import org.objectweb.hello_world_soap_http.types.GreetMeResponse;
016: import org.objectweb.hello_world_soap_http.types.GreetMeSometimeResponse;
017: import org.objectweb.hello_world_soap_http.types.NoSuchCodeLit;
018: import org.objectweb.hello_world_soap_http.types.SayHiResponse;
019: import org.objectweb.hello_world_soap_http.types.TestDocLitFaultResponse;
020:
021: @WebService(serviceName="SOAPServiceConcurrencyTest",portName="SoapPort",endpointInterface="org.objectweb.hello_world_soap_http.Greeter",targetNamespace="http://objectweb.org/hello_world_soap_http")
022: public class GreeterImpl implements Greeter {
023:
024: protected AtomicInteger greetMeCount = new AtomicInteger(0);
025: protected AtomicInteger greetMeOneWayCount = new AtomicInteger(0);
026: protected AtomicInteger sayHiCount = new AtomicInteger(0);
027: protected AtomicInteger docLitFaultCount = new AtomicInteger(0);
028: protected AtomicInteger docLitBareCount = new AtomicInteger(0);
029:
030: public String greetMe(String me) {
031: greetMeCount.incrementAndGet();
032: return "Hello " + me;
033: }
034:
035: public void greetMeOneWay(String me) {
036: greetMeOneWayCount.incrementAndGet();
037: }
038:
039: public String sayHi() {
040: sayHiCount.incrementAndGet();
041: return "Hiya";
042: }
043:
044: public void testDocLitFault(String faultType)
045: throws BadRecordLitFault, NoSuchCodeLitFault {
046: docLitFaultCount.incrementAndGet();
047: if (faultType.equals(BadRecordLitFault.class.getSimpleName())) {
048: throw new BadRecordLitFault("TestBadRecordLit",
049: "BadRecordLitFault");
050: }
051: if (faultType.equals(NoSuchCodeLitFault.class.getSimpleName())) {
052: ErrorCode ec = new ErrorCode();
053: ec.setMajor((short) 1);
054: ec.setMinor((short) 1);
055: NoSuchCodeLit nscl = new NoSuchCodeLit();
056: nscl.setCode(ec);
057: throw new NoSuchCodeLitFault("TestNoSuchCodeLit", nscl);
058: }
059: }
060:
061: public BareDocumentResponse testDocLitBare(String in) {
062: docLitBareCount.incrementAndGet();
063: BareDocumentResponse res = new BareDocumentResponse();
064: res.setCompany("Celtix");
065: res.setId(1);
066: return res;
067: }
068:
069: public String greetMeSometime(String me) {
070: return "How are you " + me;
071: }
072:
073: public Response<TestDocLitFaultResponse> testDocLitFaultAsync(
074: String faultType) {
075: return null;
076: /*not called */
077: }
078:
079: public Future<?> testDocLitFaultAsync(String faultType,
080: AsyncHandler<TestDocLitFaultResponse> asyncHandler) {
081: return null;
082: /*not called */
083: }
084:
085: public Future<?> testDocLitBareAsync(String bare, AsyncHandler ah) {
086: return null;
087: /* not called */
088: }
089:
090: public Response<BareDocumentResponse> testDocLitBareAsync(
091: String bare) {
092: return null;
093: /* not called */
094: }
095:
096: public Future<?> greetMeSometimeAsync(String requestType,
097: AsyncHandler<GreetMeSometimeResponse> asyncHandler) {
098: return null;
099: /*not called */
100: }
101:
102: public Response<GreetMeSometimeResponse> greetMeSometimeAsync(
103: String requestType) {
104: return null;
105: /*not called */
106: }
107:
108: public Future<?> greetMeAsync(String requestType,
109: AsyncHandler<GreetMeResponse> asyncHandler) {
110: return null;
111: /*not called */
112: }
113:
114: public Response<GreetMeResponse> greetMeAsync(String requestType) {
115: return null;
116: /*not called */
117: }
118:
119: public Future<?> sayHiAsync(AsyncHandler<SayHiResponse> asyncHandler) {
120: return null;
121: /*not called */
122: }
123:
124: public Response<SayHiResponse> sayHiAsync() {
125: return null;
126: /*not called */
127: }
128:
129: }
|