public class StoreDigestPerUserFilter extends StatelessFilterType {
@PostConstruct
public void addToManage(){
// -- add shedule
scheduler.scheduleAtFixedRate(new DigestRunnable(), 1, 1, TimeUnit.MINUTES);
}
/**
* Close connection pool
*/
@PreDestroy
public void close(){
log.info("StoreDigestPerUserFilter scheduler.shutdownNow()");
scheduler.shutdownNow();
}
public class DigestRunnable implements Runnable {
private final Logger log = LoggerFactory
.getLogger(DigestRunnable.class);
public void run() {
log.info(" DigestRunnable task run at " + new Date());
//TODO SendMail.send(map);
log.info(" DigestRunnable task finished at " + new Date());
}
}