From 9320e6220c2a7135e7a2ec16e0b90bb00d65cdc5 Mon Sep 17 00:00:00 2001
From: wjaniszewski <wjaniszewski@13f79535-47bb-0310-9956-ffa450edef68>
Date: Fri, 6 Mar 2009 21:57:58 +0000
Subject: 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
---
 .../sca/binding/erlang/impl/ErlangServiceBindingProvider.java | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

(limited to 'sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java')

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);
         }
-- 
cgit v1.2.3