Mercurial > hg > blitz_condensed
view src/org/dancres/blitz/notify/SendTask.java @ 0:3dc0c5604566
Initial checkin of blitz 2.0 fcs - no installer yet.
author | Dan Creswell <dan.creswell@gmail.com> |
---|---|
date | Sat, 21 Mar 2009 11:00:06 +0000 |
parents | |
children |
line wrap: on
line source
package org.dancres.blitz.notify; import java.io.IOException; import java.util.logging.*; import net.jini.space.JavaSpace; import org.dancres.blitz.task.Task; import org.dancres.blitz.disk.DiskTxn; import org.dancres.blitz.mangler.MangledEntry; /** <p> RemoteEvent dispatch occurs here. The generator is locked during generation of the RemoteEvent and any logging that may be required. </p> <p> If we fail to deliver the event to the client we take some special action. First we "taint" the generator to prevent further events being processed/dispatched, then we schedule a cleanup task to remove the registration associated with the generator. </p> */ class SendTask implements Task { private EventGenerator theGenerator; private JavaSpace theSource; private DispatchTask theTask; SendTask(JavaSpace aSource, DispatchTask aTask, EventGenerator aGenerator) { theSource = aSource; theGenerator = aGenerator; theTask = aTask; } public void run() { theGenerator.ping(theTask.getEvent(), theSource); theTask.dispatched(); } }