commit a9555ba6c621216c6d1a5cd566d80cbb3f172b0b
author Tammo van Lessen <vanto@apache.org> Wed Aug 14 22:58:41 2013 +0200
committer Tammo van Lessen <vanto@apache.org> Wed Aug 14 22:58:41 2013 +0200
tree c537f027a2928042373c2f9c5267d2f9505ce689
parent 9a3382bedd899781121c09730e6fe206d5e2e171

Allowing arbitrary return types for the OO part.

src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java

diff --git a/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java b/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java
index 462846f..10f3631 100644
--- a/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java
+++ b/src/main/java/org/apache/ode/jacob/vpu/JacobVPU.java
@@ -256,15 +256,15 @@
 
             _statistics.messagesSent++;
 
-            Synch replyChannel = null;
+            Channel replyChannel = null;
             CommChannel replyCommChannel = null;
             // Check for synchronous methods; create a synchronization channel
             if (method.getReturnType() != void.class) {
-                if (method.getReturnType() != Synch.class) {
+                if (!Channel.class.isAssignableFrom(method.getReturnType())) {
                     throw new IllegalStateException(
-                        "Channel method '" + method + "' must only return void or Synch");
+                        "Channel method '" + method + "' must only return void or an implementation of " + Channel.class.getName());
                 }
-                replyChannel = (Synch)newChannel(Synch.class, "", "Reply Channel");
+                replyChannel = newChannel(method.getReturnType(), "", "Reply Channel");
                 replyCommChannel = (CommChannel) ChannelFactory.getBackend((Channel)replyChannel);
             }