1 files changed, 8 insertions, 2 deletions

diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java
index e64728b01e..0460db2c1e 100644
--- a/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java
+++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java
@@ -21,7 +21,6 @@ package org.apache.tuscany.sca.binding.erlang.testing;
 
 import org.apache.tuscany.sca.binding.erlang.impl.types.TypeHelpersProxy;
 
-import com.ericsson.otp.erlang.OtpErlangExit;
 import com.ericsson.otp.erlang.OtpMbox;
 import com.ericsson.otp.erlang.OtpMsg;
 
@@ -33,21 +32,28 @@ public class MboxListener implements Runnable {
 	private OtpMbox mbox;
 	private OtpMsg msg;
 	private Object response;
+	private long duration;
 
 	public MboxListener(OtpMbox mbox, Object response) {
+		this(mbox, response, 0);
+	}
+	
+	public MboxListener(OtpMbox mbox, Object response, long duration) {
 		this.mbox = mbox;
 		this.response = response;
+		this.duration = duration;
 	}
 
 	public void run() {
 		try {
 			msg = mbox.receiveMsg();
+			Thread.sleep(duration);
 			if (response != null) {
 				Object[] args = new Object[1];
 				args[0] = response;
 				mbox.send(msg.getSenderPid(), TypeHelpersProxy.toErlang(args));
 			}
-		} catch (OtpErlangExit e) {
+		} catch (Exception e) {
 			e.printStackTrace();
 		}
 	}