1 files changed, 4 insertions, 3 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 8d6e2e810c..df82c5813c 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
@@ -32,6 +32,7 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
 
     private RuntimeComponentService service;
     private ErlangBinding binding;
+    private RpcServer rpcServer; 
 
     public ErlangServiceBindingProvider(ErlangBinding binding, RuntimeComponentService service) {
         this.service = service;
@@ -50,8 +51,8 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
      */
     public void start() {
         try {
-            Runnable server = new RpcServer(service, binding);
-            Thread thread = new Thread(server);
+            rpcServer = new RpcServer(service, binding);
+            Thread thread = new Thread(rpcServer);
             thread.start();
         } catch (Exception e) {
             throw new ServiceRuntimeException(e);
@@ -64,7 +65,7 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
      */
     public void stop() {
         try {
-            //TODO: stop RPC server
+        	rpcServer.stop();
         } catch (Exception e) {
             throw new ServiceRuntimeException(e);
         }