1 files changed, 30 insertions, 2 deletions
diff --git a/collaboration/GSoC-2011-Guilherme/modules/implementation-scala-runtime/src/main/java/org/apache/tuscany/sca/implementation/scala/provider/ScalaInvoker.java b/collaboration/GSoC-2011-Guilherme/modules/implementation-scala-runtime/src/main/java/org/apache/tuscany/sca/implementation/scala/provider/ScalaInvoker.java
index f9955df818..a4f90257ae 100644
--- a/collaboration/GSoC-2011-Guilherme/modules/implementation-scala-runtime/src/main/java/org/apache/tuscany/sca/implementation/scala/provider/ScalaInvoker.java
+++ b/collaboration/GSoC-2011-Guilherme/modules/implementation-scala-runtime/src/main/java/org/apache/tuscany/sca/implementation/scala/provider/ScalaInvoker.java
@@ -19,15 +19,43 @@
 
 package org.apache.tuscany.sca.implementation.scala.provider;
 
+import org.apache.tuscany.sca.implementation.scala.util.ScalaEngine;
+import org.apache.tuscany.sca.interfacedef.Operation;
 import org.apache.tuscany.sca.invocation.Invoker;
 import org.apache.tuscany.sca.invocation.Message;
 
 public class ScalaInvoker implements Invoker {
 
+	private Operation operation;
+	private ScalaEngine scalaEngine;
+	
+	public ScalaInvoker(ScalaEngine scalaEngine, Operation operation) {
+		this.operation = operation;
+		this.scalaEngine = scalaEngine;
+	}
+	
+	private Object doInvoke(Object[] objects, Operation op) throws Exception {
+
+        Operation oper = operation;  // static setting
+        if (oper.getName() == null) {  // if no static setting
+            oper = op;  // use dynamic setting
+        }
+		
+        Object response;
+        response = scalaEngine.invokeFunction(oper.getName(), objects);
+        
+        return response;        
+	}
+	
 	@Override
 	public Message invoke(Message msg) {
-		// TODO Auto-generated method stub
-		return null;
+        try {
+            Object resp = doInvoke((Object[])msg.getBody(), msg.getOperation());
+            msg.setBody(resp);
+        } catch (Exception e) {
+            msg.setFaultBody(e.getCause());
+        }
+		return msg;
 	}
 
 }