Added configurable thread pools, fixed problem with ReferenceServiceTestCase.testMultipleMethod() test case, added writing to binding processor - problems with testing

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

1 files changed, 24 insertions, 0 deletions

diff --git a/branches/sca-java-1.x/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java b/branches/sca-java-1.x/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
index 9c0e9c82e7..17fd731063 100644
--- a/branches/sca-java-1.x/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
+++ b/branches/sca-java-1.x/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
@@ -37,6 +37,10 @@ public class ErlangBindingImpl implements ErlangBinding, PolicySetAttachPoint {
 	private String module;

 	private boolean mbox;

 	private String cookie;

+	private int serviceThreadPool = DEFAULT_THREAD_POOL;

+	

+	private boolean defaultTimeout = true;

+	private boolean defaultThreads = true;

 

 	private List<Intent> requiredIntents = new ArrayList<Intent>();

 	private List<PolicySet> policySets = new ArrayList<PolicySet>();

@@ -121,6 +125,9 @@ public class ErlangBindingImpl implements ErlangBinding, PolicySetAttachPoint {
 	public void setTimeout(long timeout) {

 		// NOTE: not setting timeout or setting it to 0 will cause no timeout

 		this.timeout = timeout;

+		if (timeout != 0) {

+			defaultTimeout = false;

+		}

 	}

 

 	public String getCookie() {

@@ -139,4 +146,21 @@ public class ErlangBindingImpl implements ErlangBinding, PolicySetAttachPoint {
 		return cookie != null && cookie.length() > 0;

 	}

 

+	public int getServiceThreadPool() {

+		return serviceThreadPool;

+	}

+

+	public void setServiceThreadPool(int threads) {

+		this.serviceThreadPool = threads;

+		this.defaultThreads = false;

+	}

+

+	public boolean isDefaultServiceThreadPool() {

+		return defaultThreads;

+	}

+

+	public boolean isDefaultTimeout() {

+		return defaultTimeout;

+	}

+

 }