001: /*
002: * SharkWebServiceTestCase.java
003: *
004: * This file was auto-generated from WSDL by the Apache Axis WSDL2Java emitter.
005: */
006:
007: package org.enhydra.shark.asap.test;
008:
009: import java.net.URL;
010:
011: import org.apache.axis.types.URI;
012: import org.enhydra.shark.asap.AsapFactoryBindingStub;
013: import org.enhydra.shark.asap.SharkWebServiceLocator;
014: import org.enhydra.shark.asap.types.Request;
015: import org.enhydra.shark.asap.types.holders.GetPropertiesRsHolder;
016: import org.enhydra.shark.asap.types.holders.ResponseHolder;
017: import org.enhydra.shark.asap.types.GetPropertiesRs;
018:
019: /**
020: * JUnit test case for shark web service wrapper.
021: *
022: * @author V.Puskas
023: */
024: public class ForeignWebServiceTestCase extends junit.framework.TestCase {
025: // static private URI ik;
026:
027: public ForeignWebServiceTestCase(java.lang.String name) {
028: super (name);
029: }
030:
031: /*
032: public void test6asapObserverBindingGetProperties() throws Exception {
033: AsapObserverBindingStub binding;
034: try {
035: binding = (AsapObserverBindingStub) new SharkWebServiceLocator()
036: .getasapObserverBinding();
037: } catch (javax.xml.rpc.ServiceException jre) {
038: if (jre.getLinkedCause() != null)
039: jre.getLinkedCause().printStackTrace();
040: throw new junit.framework.AssertionFailedError(
041: "JAX-RPC ServiceException caught: " + jre);
042: }
043: assertNotNull("binding is null", binding);
044:
045: // Time out after a minute
046: binding.setTimeout(60000);
047:
048: _Request rqh = new _Request();
049: Object rqb = new java.lang.String();
050: _ResponseHolder rsh = new _ResponseHolder();
051: _GetPropertiesRsHolder rsb = new _GetPropertiesRsHolder();
052: rqh.setReceiverKey(new URI("http://vidi"));
053:
054: // Test operation
055: binding.getProperties(rqh, rqb,
056: rsh, rsb);
057: // TBD - validate results
058: }
059:
060: public void test7asapObserverBindingCompleted() throws Exception {
061: AsapObserverBindingStub binding;
062: try {
063: binding = (AsapObserverBindingStub) new SharkWebServiceLocator()
064: .getasapObserverBinding();
065: } catch (javax.xml.rpc.ServiceException jre) {
066: if (jre.getLinkedCause() != null)
067: jre.getLinkedCause().printStackTrace();
068: throw new junit.framework.AssertionFailedError(
069: "JAX-RPC ServiceException caught: " + jre);
070: }
071: assertNotNull("binding is null", binding);
072:
073: // Time out after a minute
074: binding.setTimeout(60000);
075:
076: _Request rqh = new _Request();
077: _CompletedRq rqb = new _CompletedRq();
078: _ResponseHolder rsh = new _ResponseHolder();
079: ObjectHolder rsb = new javax.xml.rpc.holders.ObjectHolder();
080: rqh.setReceiverKey(new URI("http://vidi"));
081:
082: // Test operation
083: binding.completed(rqh, rqb,
084: rsh, rsb);
085: // TBD - validate results
086: }
087:
088: public void test8asapObserverBindingStateChanged() throws Exception {
089: AsapObserverBindingStub binding;
090: try {
091: binding = (AsapObserverBindingStub) new SharkWebServiceLocator()
092: .getasapObserverBinding();
093: } catch (javax.xml.rpc.ServiceException jre) {
094: if (jre.getLinkedCause() != null)
095: jre.getLinkedCause().printStackTrace();
096: throw new junit.framework.AssertionFailedError(
097: "JAX-RPC ServiceException caught: " + jre);
098: }
099: assertNotNull("binding is null", binding);
100:
101: // Time out after a minute
102: binding.setTimeout(60000);
103:
104: _Request rqh = new _Request();
105: _StateChangedRq rqb = new _StateChangedRq();
106: _ResponseHolder rsh = new _ResponseHolder();
107: ObjectHolder rsb = new javax.xml.rpc.holders.ObjectHolder();
108:
109: rqh.setReceiverKey(new URI("http://vidi"));
110: // Test operation
111: binding.stateChanged(rqh, rqb,
112: rsh, rsb);
113: // TBD - validate results
114: }
115: */
116: public void test9asapFactoryBindingGetProperties() throws Exception {
117: AsapFactoryBindingStub binding;
118: String uriString;
119: //uriString = "http://interop.i-flow.com/iflowjsp/jsp/ProcDef.jsp?planName=Manufacturer";
120: uriString = "http://www.staffware.co.za:8080/ASAPServer/FactoryService.asmx";
121: //uriString = "http://68.96.20.206:7787/asap_evm";;
122: //uriString = "http://interop.i-flow.com/iflowjsp/jsp/ProcDef.jsp?planName=Retailer";
123:
124: try {
125: binding = (AsapFactoryBindingStub) new SharkWebServiceLocator()
126: //.getasapFactoryBinding(new URL());
127: .getasapFactoryBinding(new URL(uriString));
128: //
129: } catch (javax.xml.rpc.ServiceException jre) {
130: if (jre.getLinkedCause() != null)
131: jre.getLinkedCause().printStackTrace();
132: throw new junit.framework.AssertionFailedError(
133: "JAX-RPC ServiceException caught: " + jre);
134: }
135: assertNotNull("binding is null", binding);
136:
137: // Time out after a minute
138: binding.setTimeout(60000);
139: Request rqHead = new Request();
140: String rqBody = ""; // new java.lang.String()
141: ResponseHolder rsHead = new ResponseHolder();
142: GetPropertiesRsHolder rsBody = new GetPropertiesRsHolder();
143: rqHead.setReceiverKey(new URI(uriString));
144:
145: // Test operation
146: try {
147: binding.getProperties(rqHead, rqBody, rsHead, rsBody);
148: } catch (Throwable t) {
149: System.err.println("Throwable " + t.getClass().getName()
150: + "(" + t.getMessage() + ")");
151: }
152: Object[] oo = binding.getResponseHeaders();
153: for (int n = 0; n < oo.length; ++n) {
154: System.err.println("" + n + "#"
155: + binding.getResponseHeaders()[n].toString());
156: }
157: // TBD - validate results
158: System.err.println("res" + rsBody.value);
159: GetPropertiesRs fpg = rsBody.value;
160: System.err.println("Key=" + fpg.getKey());
161: System.err.println("Name=" + fpg.getName());
162: System.err.println("Subj=" + fpg.getSubject());
163: System.err.println("desc=" + fpg.getDescription());
164: System.err.println("cds="
165: + fpg.getContextDataSchema().get_any()[0].toString());
166: System.err.println("rds="
167: + fpg.getResultDataSchema().get_any()[0].toString());
168: }
169: /*
170: public void test10asapFactoryBindingCreateInstance() throws Exception {
171: AsapFactoryBindingStub binding;
172: try {
173: binding = (AsapFactoryBindingStub) new SharkWebServiceLocator()
174: .getasapFactoryBinding();
175: } catch (javax.xml.rpc.ServiceException jre) {
176: if (jre.getLinkedCause() != null)
177: jre.getLinkedCause().printStackTrace();
178: throw new junit.framework.AssertionFailedError(
179: "JAX-RPC ServiceException caught: " + jre);
180: }
181: assertNotNull("binding is null", binding);
182:
183: // Time out after a minute
184: binding.setTimeout(60000);
185:
186: _Request rqHead = new _Request();
187: _CreateInstanceRq rqBody = new _CreateInstanceRq();
188: _ResponseHolder rsHead = new _ResponseHolder();
189: _CreateInstanceRsHolder rsBody = new _CreateInstanceRsHolder();
190:
191: rqHead.setReceiverKey(new URI(new SharkWebServiceLocator()
192: .getasapFactoryBindingAddress()));
193: //rqHead.getReceiverKey().setQueryString("procMgr=test_js+1+basic");
194: //rqHead.getReceiverKey().setQueryString("procDef=manufacturing&packageId=test_js");
195: rqHead.getReceiverKey().setQueryString("procDef=Game&packageId=test_js");
196: rqBody.setObserverKey(new URI(new SharkWebServiceLocator()
197: .getasapObserverBindingAddress()));
198: rqBody.getObserverKey().setHost(InetAddress.getLocalHost().getHostName());
199: rqBody.setStartImmediately(true);
200: // Test operation
201: binding.createInstance(rqHead, rqBody, rsHead, rsBody);
202: System.err.println("##" + rsBody.value.getInstanceKey());
203: // TBD - validate results
204: ik = rsBody.value.getInstanceKey();
205: }
206:
207: public void test11asapFactoryBindingListInstances() throws Exception {
208: AsapFactoryBindingStub binding;
209: try {
210: binding = (AsapFactoryBindingStub) new SharkWebServiceLocator()
211: .getasapFactoryBinding();
212: } catch (javax.xml.rpc.ServiceException jre) {
213: if (jre.getLinkedCause() != null)
214: jre.getLinkedCause().printStackTrace();
215: throw new junit.framework.AssertionFailedError(
216: "JAX-RPC ServiceException caught: " + jre);
217: }
218: assertNotNull("binding is null", binding);
219:
220: // Time out after a minute
221: binding.setTimeout(60000);
222:
223: _Request rqh = new _Request();
224: rqh.setReceiverKey(new URI(new SharkWebServiceLocator()
225: .getasapFactoryBindingAddress()));
226: //rqh.getReceiverKey().setQueryString("procMgr=test_js+1+basic");
227: //rqh.getReceiverKey().setQueryString("procDef=manufacturing&packageId=test_js");
228:
229: _ListInstancesRq rqb = new _ListInstancesRq();
230: _ResponseHolder rsh = new _ResponseHolder();
231: _ListInstancesRsHolder rsb = new _ListInstancesRsHolder();
232: // Test operation
233: binding.listInstances(rqh, rqb, rsh, rsb);
234: _Instance[] a = rsb.value.getInstance();
235: if (null != a) {
236: for (int n = 0; n < a.length; ++n) {
237: //System.err.println(a[n]);
238: System.err.println("[" + a[n].getInstanceKey() + ", "
239: + a[n].getName() + ", " + a[n].getSubject() + "]");
240: }
241: } else {
242: System.err.println("getInstance value is null");
243: }
244: // TBD - validate results
245: }
246:
247: public void test2asapInstanceBindingSetProperties() throws Exception {
248: AsapInstanceBindingStub binding;
249: try {
250: binding = (AsapInstanceBindingStub) new SharkWebServiceLocator()
251: .getasapInstanceBinding();
252: } catch (javax.xml.rpc.ServiceException jre) {
253: if (jre.getLinkedCause() != null)
254: jre.getLinkedCause().printStackTrace();
255: throw new junit.framework.AssertionFailedError(
256: "JAX-RPC ServiceException caught: " + jre);
257: }
258: assertNotNull("binding is null", binding);
259:
260: // Time out after a minute
261: binding.setTimeout(60000);
262:
263: _Request rqh = new _Request();
264: _SetPropertiesRq rqb = new _SetPropertiesRq();
265: _ResponseHolder rsh = new _ResponseHolder();
266: _SetPropertiesRsHolder rsb = new _SetPropertiesRsHolder();
267: rqh.setReceiverKey(new URI("http://vidi"));
268:
269: // Test operation
270: binding.setProperties(rqh, rqb,
271: rsh, rsb);
272: // TBD - validate results
273: }
274:
275: public void test3asapInstanceBindingSubscribe() throws Exception {
276: AsapInstanceBindingStub binding;
277: try {
278: binding = (AsapInstanceBindingStub) new SharkWebServiceLocator()
279: .getasapInstanceBinding();
280: } catch (javax.xml.rpc.ServiceException jre) {
281: if (jre.getLinkedCause() != null)
282: jre.getLinkedCause().printStackTrace();
283: throw new junit.framework.AssertionFailedError(
284: "JAX-RPC ServiceException caught: " + jre);
285: }
286: assertNotNull("binding is null", binding);
287:
288: // Time out after a minute
289: binding.setTimeout(60000);
290:
291: _Request rqh = new _Request();
292: _SubscribeRq rqb = new _SubscribeRq();
293: _ResponseHolder rsh = new _ResponseHolder();
294: ObjectHolder rsb = new javax.xml.rpc.holders.ObjectHolder();
295: rqh.setReceiverKey(ik);
296: rqb.setObserverKey(new URI(new SharkWebServiceLocator()
297: .getasapObserverBindingAddress()));
298: // Test operation
299: binding.subscribe(rqh, rqb, rsh, rsb);
300: // TBD - validate results
301: }
302:
303: public void test1asapInstanceBindingGetProperties() throws Exception {
304: AsapInstanceBindingStub binding;
305: try {
306: binding = (AsapInstanceBindingStub) new SharkWebServiceLocator()
307: .getasapInstanceBinding();
308: } catch (javax.xml.rpc.ServiceException jre) {
309: if (jre.getLinkedCause() != null)
310: jre.getLinkedCause().printStackTrace();
311: throw new junit.framework.AssertionFailedError(
312: "JAX-RPC ServiceException caught: " + jre);
313: }
314: assertNotNull("binding is null", binding);
315:
316: // Time out after a minute
317: binding.setTimeout(60000);
318:
319: _Request rqh = new _Request();
320: Object rqb = new java.lang.String();
321: _ResponseHolder rsh = new _ResponseHolder();
322: _GetPropertiesRsHolder rsb = new _GetPropertiesRsHolder();
323: rqh.setReceiverKey(ik);
324:
325: System.err.println("##tt");
326: // Test operation
327: binding.getProperties(rqh, rqb, rsh, rsb);
328: InstancePropertiesGroup ipg = rsb.value.getInstancePropertiesGroup();
329: System.err.println("#ipg:"+ipg.getKey());
330: System.err.println("#ipg:"+ipg.getFactoryKey());
331: URI[] _obs_ = ipg.getObservers().getObserverKey();
332: for (int n = 0; n < _obs_.length; ++n) {
333: System.err.println("#ipg"+n+":"+_obs_[n]);
334: }
335: _Event[] _ev_ = ipg.getHistory().getEvent();
336: for (int n = 0; n <_ev_.length; ++n) {
337: System.err.println("#ipg"+n+"event:"+_ev_[n].getEventType());
338: System.err.println("#ipg"+n+"event:"+_ev_[n].getTime());
339: }
340: MessageElement[] ctx = ipg.getContextData().get_any();
341: for (int n = 0; n <ctx.length; ++n) {
342: System.err.println("#ipg"+n+"ctx:"+ctx[n].toString());
343: }
344: }
345:
346: public void test4asapInstanceBindingUnsubscribe() throws Exception {
347: AsapInstanceBindingStub binding;
348: try {
349: binding = (AsapInstanceBindingStub) new SharkWebServiceLocator()
350: .getasapInstanceBinding();
351: } catch (javax.xml.rpc.ServiceException jre) {
352: if (jre.getLinkedCause() != null)
353: jre.getLinkedCause().printStackTrace();
354: throw new junit.framework.AssertionFailedError(
355: "JAX-RPC ServiceException caught: " + jre);
356: }
357: assertNotNull("binding is null", binding);
358:
359: // Time out after a minute
360: binding.setTimeout(60000);
361:
362: _Request rqh = new _Request();
363: _UnsubscribeRq rqb = new _UnsubscribeRq();
364: _ResponseHolder rsh = new _ResponseHolder();
365: ObjectHolder rsb = new javax.xml.rpc.holders.ObjectHolder();
366: rqh.setReceiverKey(ik);
367: rqb.setObserverKey(new URI(new SharkWebServiceLocator()
368: .getasapObserverBindingAddress()));
369:
370: // Test operation
371: binding.unsubscribe(rqh, rqb, rsh, rsb);
372: // TBD - validate results
373: }
374:
375: public void test5asapInstanceBindingChangeState() throws Exception {
376: System.err.println("##ibcss");
377: AsapInstanceBindingStub binding;
378: try {
379: binding = (AsapInstanceBindingStub) new SharkWebServiceLocator()
380: .getasapInstanceBinding();
381: } catch (javax.xml.rpc.ServiceException jre) {
382: if (jre.getLinkedCause() != null)
383: jre.getLinkedCause().printStackTrace();
384: throw new junit.framework.AssertionFailedError(
385: "JAX-RPC ServiceException caught: " + jre);
386: }
387: assertNotNull("binding is null", binding);
388:
389: // Time out after a minute
390: binding.setTimeout(60000);
391:
392:
393: _Request rqh = new _Request();
394: _ChangeStateRq rqb = new _ChangeStateRq();
395: _ResponseHolder rsh = new _ResponseHolder();
396: _ChangeStateRsHolder rsb = new _ChangeStateRsHolder();
397: rqh.setReceiverKey(ik);
398: rqb.setState(StateType.value6);
399:
400: // Test operation
401: binding.changeState(rqh, rqb, rsh, rsb);
402: // TBD - validate results
403: System.err.println("##ibcse");
404:
405:
406: }
407: */
408: }
|