summaryrefslogtreecommitdiffstats
path: root/sandbox/sebastien/java/wrapped/samples/extending-tuscany/implementation-sample/src/main/java/sample/impl/SampleWSDLProxy.java
diff options
context:
space:
mode:
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.java30
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();
- }
-
- }
}