1 31 package org.objectweb.proactive.core.body.reply; 32 33 import org.objectweb.proactive.core.body.UniversalBody; 34 import org.objectweb.proactive.core.body.future.FuturePool; 35 import org.objectweb.proactive.Body; 36 37 public class ReplyReceiverForwarder implements ReplyReceiver { 38 39 private UniversalBody remoteBody; 40 41 public ReplyReceiverForwarder(UniversalBody b) { 42 this.remoteBody = b; 43 } 44 45 46 public void receiveReply(Reply reply, Body receiverBody, FuturePool futurePool) throws java.io.IOException { 47 reply.send(remoteBody); 48 } 49 } 50 | Popular Tags |