view src/org/dancres/blitz/notify/CleanTask.java @ 28:4b2f23b6feca

Add a schema compatibility check to indexer that parallels storage.
author Dan Creswell <dan.creswell@gmail.com>
date Sat, 12 Jun 2010 10:11:15 +0100
parents 3dc0c5604566
children
line wrap: on
line source

package org.dancres.blitz.notify;

import java.io.IOException;

import java.util.logging.*;

import org.dancres.blitz.task.Task;

import org.dancres.blitz.disk.DiskTxn;

import org.dancres.blitz.oid.OID;

/**
   If SendTask determines that a particular client and it's associated
   notify() registration are no longer useful (due to particular exceptions
   being received from the client), an instance of this task will be scheduled
   to do the cleanup.
 */
class CleanTask implements Task {
    private OID theId;

    CleanTask(OID anId) {
        theId = anId;
    }

    public void run() {
        try {
            EventGeneratorFactory.get().killTemplate(theId);
        } catch (IOException anIOE) {
            RemoteEventDispatcher.theLogger.log(Level.SEVERE,
                                                "Failed to clean dead lease",
                                                anIOE);
        }
    }
}