1 files changed, 6 insertions, 7 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 38b9b197d6..c2546a4336 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,13 +32,11 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
 
 	private RuntimeComponentService service;
 	private ErlangNode node;
-	private ErlangBinding binding;
 
-	public ErlangServiceBindingProvider(ErlangNode node, ErlangBinding binding,
-			RuntimeComponentService service) {
+	public ErlangServiceBindingProvider(ErlangBinding binding,
+			RuntimeComponentService service) throws Exception {
 		this.service = service;
-		this.binding = binding;
-		this.node = node;
+		this.node  = new ErlangNode(binding.getNode(), binding, service);
 	}
 
 	/**
@@ -53,7 +51,8 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
 	 */
 	public void start() {
 		try {
-			node.registerBinding(binding, service);
+			Thread thread = new Thread(node);
+			thread.start();
 		} catch (Exception e) {
 			throw new ServiceRuntimeException(e);
 		}
@@ -65,7 +64,7 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
 	 */
 	public void stop() {
 		try {
-			node.unregisterBinding(binding);
+			node.stop();
 		} catch (Exception e) {
 			throw new ServiceRuntimeException(e);
 		}