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);
         }