X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b558f9b18c938af6a35ebea66ac2323a60178202..4e78565ea6b354a0e6250a87b483f909665a0ac3:/examples/java/cloud/Slave.java diff --git a/examples/java/cloud/Slave.java b/examples/java/cloud/Slave.java index 8f7cde3384..01e646ff89 100644 --- a/examples/java/cloud/Slave.java +++ b/examples/java/cloud/Slave.java @@ -21,9 +21,15 @@ public class Slave extends Process { public void main(String[] args) throws MsgException { while(true) { Msg.info("Receiving on " + "slave_" + number); - Task task = Task.receive("slave_"+number); - + Task task; + try { + task = Task.receive("slave_"+number); + } catch (MsgException e) { + Msg.debug("Received failed. I'm done. See you!"); + break; + } if (task instanceof FinalizeTask) { + Msg.info("Received Finalize. I'm done. See you!"); break; } Msg.info("Received \"" + task.getName() + "\". Processing it."); @@ -35,7 +41,6 @@ public class Slave extends Process { Msg.info("\"" + task.getName() + "\" done "); } - Msg.info("Received Finalize. I'm done. See you!"); } } \ No newline at end of file