diff options
Diffstat (limited to 'sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLProxy.java')
-rw-r--r-- | sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLProxy.java | 30 |
1 files changed, 3 insertions, 27 deletions
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(); - } - - } } |