diff options
author | wjaniszewski <wjaniszewski@13f79535-47bb-0310-9956-ffa450edef68> | 2009-03-02 22:49:01 +0000 |
---|---|---|
committer | wjaniszewski <wjaniszewski@13f79535-47bb-0310-9956-ffa450edef68> | 2009-03-02 22:49:01 +0000 |
commit | 65c9710b644bd3ef0f5dd21aaa0049f984394c57 (patch) | |
tree | e67b40fea3ffe03bc0d28f0fbca5e020ef49fcc9 /sandbox/wjaniszewski/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java | |
parent | 6c6ad2fbdd72a4aabc4025339a3d6aa090668444 (diff) |
Epmd starts automatically - if epmd is not available tests are beeing ignored. Normalized service/reference RPC, added some error handling.
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@749461 13f79535-47bb-0310-9956-ffa450edef68
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 | 60 |
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; + } } |