diff options
| -rw-r--r-- | sca-java-2.x/trunk/unreleased/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/sca-java-2.x/trunk/unreleased/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java b/sca-java-2.x/trunk/unreleased/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java index aa99051f2d..dfd4091488 100644 --- a/sca-java-2.x/trunk/unreleased/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java +++ b/sca-java-2.x/trunk/unreleased/modules/binding-comet-runtime/src/main/java/org/apache/tuscany/sca/binding/comet/runtime/handler/CometBindingHandler.java @@ -127,9 +127,12 @@ public class CometBindingHandler { final Operation operation = context.getOperation(url); final Object[] args = decodeJsonDataForOperation(jsonData, operation); - Message msg = createMessageWithMockedCometReference(args, callbackMethod); - Object response = wire.invoke(operation, args); - System.out.println("Response: " + gson.toJson(response)); + // Message msg = createMessageWithMockedCometReference(args, + // callbackMethod); + Message msg = new MessageImpl(); + msg.setBody(args); + msg.setOperation(operation); + wire.invokeAsync(msg); } /** |