1 files changed, 26 insertions, 34 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 61e814b740..b5d5e67b00 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
@@ -27,39 +27,31 @@ import com.ericsson.otp.erlang.OtpMsg;
 
 public class MboxListener implements Runnable {
 
-    private static final long TEST_TIMEOUT = 500;
-    
-    private OtpMbox mbox;
-    private OtpMsg msg;
-    private Object response;
-    
-    public MboxListener(OtpMbox mbox, Object response) {
-        this.mbox = mbox;
-        this.response = response;
-    }
-    
-    public void run() {
-        try {
-            try {
-                msg = mbox.receiveMsg(TEST_TIMEOUT);
-
-                if (response != null) {
-                    Object[] args = new Object[1];
-                    args[0] = response;
-                    mbox.send(msg.getSenderPid(), TypeHelpersProxy.toErlang(args));
-                }
-            } catch (InterruptedException e) {
-                // TODO Auto-generated catch block
-                e.printStackTrace();
-            }
-        } catch (OtpErlangExit e) {
-            // TODO Auto-generated catch block
-            e.printStackTrace();
-        }
-    }
-
-    public OtpMsg getMsg() {
-        return msg;
-    }
+	private OtpMbox mbox;
+	private OtpMsg msg;
+	private Object response;
+
+	public MboxListener(OtpMbox mbox, Object response) {
+		this.mbox = mbox;
+		this.response = response;
+	}
+
+	public void run() {
+		try {
+			msg = mbox.receiveMsg();
+
+			if (response != null) {
+				Object[] args = new Object[1];
+				args[0] = response;
+				mbox.send(msg.getSenderPid(), TypeHelpersProxy.toErlang(args));
+			}
+		} catch (OtpErlangExit e) {
+			e.printStackTrace();
+		}
+	}
+
+	public OtpMsg getMsg() {
+		return msg;
+	}
 
 }