diff options
Diffstat (limited to 'sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main')
3 files changed, 26 insertions, 54 deletions
diff --git a/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/api/WSDLReference.java b/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/api/WSDLReference.java index a25df3e895..528ff530c2 100644 --- a/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/api/WSDLReference.java +++ b/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/api/WSDLReference.java @@ -23,8 +23,7 @@ import org.w3c.dom.Element; public interface WSDLReference { - Element call(String op, Element e); - public Element callBare(String op, Element... e); - void callAsync(String op, Element e); + Element doccall(String op, Element e); + public Object rpccall(String op, Object... args); } diff --git a/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLInvoker.java b/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLInvoker.java index 6758c1fc1f..3f68d5d219 100644 --- a/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLInvoker.java +++ b/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLInvoker.java @@ -39,12 +39,22 @@ import org.w3c.dom.Element; class SampleWSDLInvoker extends InterceptorAsyncImpl { final String name; final Object instance; - final Method method; + final Method doccall; + final Method rpccall; + + static Method method(final Class<?> clazz, final String name, final Class<?>... types) { + try { + return clazz.getMethod("doccall", String.class, Element.class); + } catch (Exception e) { + return null; + } + } SampleWSDLInvoker(final WSDLOperation op, final Class<?> clazz, final Object instance) throws SecurityException, NoSuchMethodException { this.name = op.getName(); this.instance = instance; - this.method = clazz.getMethod("call", String.class, Element.class); + this.doccall = method(clazz, "doccall", String.class, Element.class); + this.rpccall = method(clazz, "rpccall", String.class, Object[].class); } public Invoker getNext() { @@ -56,31 +66,18 @@ class SampleWSDLInvoker extends InterceptorAsyncImpl { return processRequest(msg); } - public void invokeAsyncRequest(Message msg) { - // Retrieve the async callback information - AsyncResponseInvoker respInvoker = (AsyncResponseInvoker)msg.getHeaders().get("ASYNC_RESPONSE_INVOKER"); - if( respInvoker == null ) throw new ServiceRuntimeException("Async Implementation invoked with no response invoker"); - - Message responseMsg = processRequest(msg); - - // in this sample programming model we make the async - // response from the implementation provider. The - // component implementation itself doesn't get a chance to - // do async responses. - - // At this point we could serialize the AsyncResponseInvoker and pick it up again - // later to send the async response - - //((RuntimeEndpoint)msg.getTo()).invokeAsyncResponse(responseMsg); - respInvoker.invokeAsyncResponse(responseMsg); - } // end method invokeAsyncRequest - public Message processRequest(Message msg) { try { - //AsyncHeader asyncHeader = (String) message.getHeaders().get("ASYNC-HEADER"); // Invoke the generic call method - Object response = method.invoke(instance, name, ((Object[])msg.getBody())[0]); - msg.setBody(response); + if (doccall != null) { + // Document style (args wrapped in a single wrapper element) + final Object response = doccall.invoke(instance, name, ((Object[])msg.getBody())[0]); + msg.setBody(response); + } else { + // RPC style (args are passed as an array) + final Object response = rpccall.invoke(instance, name, (Object[])msg.getBody()); + msg.setBody(response); + } } catch(Exception e) { e.printStackTrace(); msg.setFaultBody(e.getCause()); diff --git a/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLProxy.java b/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLProxy.java index 5b42bce28f..707e71c187 100644 --- a/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLProxy.java +++ b/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLProxy.java @@ -58,7 +58,7 @@ class SampleWSDLProxy implements WSDLReference { } @Override - public Element call(String op, Element e) { + public Element doccall(String op, Element e) { try { // Invoke the named operation on the endpoint reference return (Element)repr.invoke(ops.get(op), new Object[] {e}); @@ -68,37 +68,13 @@ class SampleWSDLProxy implements WSDLReference { } @Override - public Element callBare(String op, Element... e) { + public Object rpccall(String op, Object... args) { try { // Invoke the named operation on the endpoint reference - return (Element)repr.invoke(ops.get(op), e); + return repr.invoke(ops.get(op), args); } catch(InvocationTargetException ex) { throw new RuntimeException(ex); } } - @Override - public void callAsync(String op, Element e) { - // Asynchronously invoke the named operation on the endpoint reference - Message message = mf.createMessage(); - message.setBody(new Object[]{e}); - - // Generate MESSAGE_ID here. - // String messageID = "myuniqueid"; - String messageID = UUID.randomUUID().toString(); - message.getHeaders().put(Constants.MESSAGE_ID, messageID); - - // save the message id ready for when we process the response - asyncMessageMap.put(messageID, op); - - // We could add implementation specific headers here if required - //message.getHeaders().put(Constants.???, ???); - - try { - repr.invokeAsync(ops.get(op), message); - } catch (Throwable ex) { - ex.printStackTrace(); - } - - } } |