- CommTimeTask task = new CommTimeTask("finalize_" + i,0,0);
- task.setData(221297);
-
- Msg.info("Send task to host : " + slaves[i].getName());
- channel.put(task,slaves[i]);
-
- Msg.info("Send completed " + slaves[i].getName() + " [" + i + "]");
+ Msg.info("Finalize host " + slaves[i].getName() + " [" + i + "]");
+ slaves[i].put(0, new FinalizeTask());