diff options
Diffstat (limited to 'sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java')
-rw-r--r-- | sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java | 10 |
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(); } } |