Service RPC updated by allowing to have more than one SCA-Erlang module on single SCA-Erlang node

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@751092 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 6 deletions

diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java
index df82c5813c..651067f4e7 100644
--- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java
+++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java
@@ -31,12 +31,13 @@ import org.osoa.sca.ServiceRuntimeException;
 public class ErlangServiceBindingProvider implements ServiceBindingProvider {

 

     private RuntimeComponentService service;

+    private ErlangNode node;

     private ErlangBinding binding;

-    private RpcServer rpcServer; 

 

-    public ErlangServiceBindingProvider(ErlangBinding binding, RuntimeComponentService service) {

+    public ErlangServiceBindingProvider(ErlangNode node, ErlangBinding binding, RuntimeComponentService service) {

         this.service = service;

         this.binding = binding;

+        this.node = node;

     }

 

     /**

@@ -51,9 +52,7 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
      */

     public void start() {

         try {

-            rpcServer = new RpcServer(service, binding);

-            Thread thread = new Thread(rpcServer);

-            thread.start();

+            node.registerModule(binding, service);

         } catch (Exception e) {

             throw new ServiceRuntimeException(e);

         }

@@ -65,7 +64,7 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
      */

     public void stop() {

         try {

-        	rpcServer.stop();

+        	node.unregisterModule(binding);

         } catch (Exception e) {

             throw new ServiceRuntimeException(e);

         }