summaryrefslogtreecommitdiffstats
path: root/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java
diff options
context:
space:
mode:
authorwjaniszewski <wjaniszewski@13f79535-47bb-0310-9956-ffa450edef68>2009-03-02 22:49:01 +0000
committerwjaniszewski <wjaniszewski@13f79535-47bb-0310-9956-ffa450edef68>2009-03-02 22:49:01 +0000
commit65c9710b644bd3ef0f5dd21aaa0049f984394c57 (patch)
treee67b40fea3ffe03bc0d28f0fbca5e020ef49fcc9 /sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java
parent6c6ad2fbdd72a4aabc4025339a3d6aa090668444 (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/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java')
-rw-r--r--sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java7
1 files changed, 4 insertions, 3 deletions
diff --git a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java
index 8d6e2e810c..df82c5813c 100644
--- a/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java
+++ b/sandbox/wjaniszewski/binding-erlang-runtime/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangServiceBindingProvider.java
@@ -32,6 +32,7 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
private RuntimeComponentService service;
private ErlangBinding binding;
+ private RpcServer rpcServer;
public ErlangServiceBindingProvider(ErlangBinding binding, RuntimeComponentService service) {
this.service = service;
@@ -50,8 +51,8 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
*/
public void start() {
try {
- Runnable server = new RpcServer(service, binding);
- Thread thread = new Thread(server);
+ rpcServer = new RpcServer(service, binding);
+ Thread thread = new Thread(rpcServer);
thread.start();
} catch (Exception e) {
throw new ServiceRuntimeException(e);
@@ -64,7 +65,7 @@ public class ErlangServiceBindingProvider implements ServiceBindingProvider {
*/
public void stop() {
try {
- //TODO: stop RPC server
+ rpcServer.stop();
} catch (Exception e) {
throw new ServiceRuntimeException(e);
}