Added configurable timeout and cookies for service bindings. Consequence is that one SCA-Erlang node is created excusively for one service binding, so service bindings cannot share the same value in 'node' attribute like it was before. Made some other fixes.

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

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

 		}