1 files changed, 103 insertions, 78 deletions
diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
index 36b8df9fab..ad1bec06d3 100644
--- a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
+++ b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
@@ -33,83 +33,108 @@ import org.apache.tuscany.sca.policy.PolicySetAttachPoint;
  */
 public class ErlangBindingImpl implements ErlangBinding, PolicySetAttachPoint {
 
-    private String node;
-    private String module;
-    private boolean mbox;
-    
-    private List<Intent> requiredIntents = new ArrayList<Intent>();
-    private List<PolicySet> policySets = new ArrayList<PolicySet>();
-    private IntentAttachPointType intentAttachPointType;
-    private List<PolicySet> applicablePolicySets = new ArrayList<PolicySet>();
-
-    public String getNode() {
-        return node;
-    }
-
-    public void setNode(String nodeName) {
-        this.node = nodeName;
-    }
-
-    public String getName() {
-        return null;
-    }
-
-    public String getURI() {
-        return null;
-    }
-
-    public void setName(String arg0) {
-    }
-
-    public void setURI(String arg0) {
-    }
-
-    public boolean isUnresolved() {
-        return false;
-    }
-
-    public void setUnresolved(boolean arg0) {
-    }
-
-    public List<PolicySet> getApplicablePolicySets() {
-        return applicablePolicySets;
-    }
-
-    public List<PolicySet> getPolicySets() {
-        return policySets;
-    }
-
-    public List<Intent> getRequiredIntents() {
-        return requiredIntents;
-    }
-
-    public IntentAttachPointType getType() {
-        return intentAttachPointType;
-    }
-
-    public void setType(IntentAttachPointType intentAttachPointType) {
-        this.intentAttachPointType = intentAttachPointType;
-    }
-    
-    @Override
-    public Object clone() throws CloneNotSupportedException {
-        return super.clone();
-    }
-
-    public String getModule() {
-        return module;
-    }
-
-    public boolean isMbox() {
-        return mbox;
-    }
-
-    public void setMbox(boolean mbox) {
-        this.mbox = mbox;
-    }
-
-    public void setModule(String module) {
-        this.module = module;
-    }
+	public static final long DEFAULT_TIMEOUT = 10000;
+
+	private String node;
+	private String module;
+	private boolean mbox;
+	private String cookie;
+
+	private List<Intent> requiredIntents = new ArrayList<Intent>();
+	private List<PolicySet> policySets = new ArrayList<PolicySet>();
+	private IntentAttachPointType intentAttachPointType;
+	private List<PolicySet> applicablePolicySets = new ArrayList<PolicySet>();
+	private long timeout = DEFAULT_TIMEOUT;
+
+	public String getNode() {
+		return node;
+	}
+
+	public void setNode(String nodeName) {
+		this.node = nodeName;
+	}
+
+	public String getName() {
+		return null;
+	}
+
+	public String getURI() {
+		return null;
+	}
+
+	public void setName(String arg0) {
+	}
+
+	public void setURI(String arg0) {
+	}
+
+	public boolean isUnresolved() {
+		return false;
+	}
+
+	public void setUnresolved(boolean arg0) {
+	}
+
+	public List<PolicySet> getApplicablePolicySets() {
+		return applicablePolicySets;
+	}
+
+	public List<PolicySet> getPolicySets() {
+		return policySets;
+	}
+
+	public List<Intent> getRequiredIntents() {
+		return requiredIntents;
+	}
+
+	public IntentAttachPointType getType() {
+		return intentAttachPointType;
+	}
+
+	public void setType(IntentAttachPointType intentAttachPointType) {
+		this.intentAttachPointType = intentAttachPointType;
+	}
+
+	@Override
+	public Object clone() throws CloneNotSupportedException {
+		return super.clone();
+	}
+
+	public String getModule() {
+		return module;
+	}
+
+	public boolean isMbox() {
+		return mbox;
+	}
+
+	public void setMbox(boolean mbox) {
+		this.mbox = mbox;
+	}
+
+	public void setModule(String module) {
+		this.module = module;
+	}
+
+	public long getTimeout() {
+		return timeout;
+	}
+
+	public void setTimeout(long timeout) {
+		// NOTE: 0 timeout will cause setting to default
+		if (timeout == 0) {
+			this.timeout = DEFAULT_TIMEOUT;
+		} else {
+			this.timeout = timeout;
+		}
+	}
+
+	public String getCookie() {
+		return cookie;
+	}
+
+	public void setCookie(String cookie) {
+		this.cookie = cookie;
+	}
 
 }