1 46 package org.mr.kernel; 47 48 import org.mr.MantaAgent; 49 import org.mr.core.protocol.MantaBusMessage; 50 import org.mr.core.util.TimeoutTimer; 51 import org.mr.core.util.Timeoutable; 52 53 58 public class DelayedMessageSender implements Timeoutable { 59 TimeoutTimer timer = null; 60 61 public DelayedMessageSender(){ 62 timer = new TimeoutTimer("DelayedMessageSender",1000,1); 63 } 64 65 70 public void send(MantaBusMessage msg, int delay){ 71 timer.addTimeout(this, msg ,delay*1000 ); 72 } 73 74 public void timeout(Object event) { 75 MantaBusMessage msg = (MantaBusMessage) event; 76 MantaAgent.getInstance().send(msg, msg.getSource()); 77 78 } 79 80 } 81 | Popular Tags |