summaryrefslogtreecommitdiffstats
path: root/branches/sca-java-1.x/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'branches/sca-java-1.x/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java')
-rw-r--r--branches/sca-java-1.x/modules/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java24
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;
+ }
+
}