Examples of MailJob

com.taobao.zeus.jobs.sub.tool.MailJob
org.opencustomer.connector.scheduling.jobs.MailJob
The class MailJob sends a single email on the alarm date. Every sub class of Email kann be send by this job. You have to add this job th se SchedulingManager. Normaly the LoadDailyMailJob job adds these MailJobs to the SchedulingManager. @author fbreske

Examples of com.taobao.zeus.jobs.sub.tool.MailJob

        ZooKeeperProcesser zkp=(ZooKeeperProcesser)p;
        if(!zkp.getUseDefault()){
          jobs.add(new ZooKeeperJob(jobContext, (ZooKeeperProcesser) p,applicationContext));
        }
      }else if(p instanceof MailProcesser){
        jobs.add(new MailJob(jobContext, (MailProcesser)p, applicationContext));
      }else if(p instanceof WangWangProcesser){
        jobs.add(new WangWangJob(jobContext));
      }else if(p instanceof OutputCheckProcesser){
        jobs.add(new OutputCheckJob(jobContext, (OutputCheckProcesser)p, applicationContext));
      }else if(p instanceof OutputCleanProcesser){

View Full Code Here

Examples of org.opencustomer.connector.scheduling.jobs.MailJob

                log.warn("cannot create reminder mail, incorrect sender address");
                return;
            }
            
            reminderMail.setJob(job);
            MailJob mailJob = new MailJob(reminderMail);
            
            for(Object obj :  manager.getAlarmManager().getAllAlarms())
            {
                AlarmEntry alarmEntry = (AlarmEntry) obj;
                String name;

View Full Code Here

Examples of org.opencustomer.connector.scheduling.jobs.MailJob

                    reminderMail.setEvent(event.getEvent());
                    try
                    {
                        reminderMail.setUser(user);
                        
                        MailJob mailJob = new MailJob(reminderMail);
                        
                        for(Object obj :  manager.getAlarmManager().getAllAlarms())
                        {
                            AlarmEntry alarmEntry = (AlarmEntry) obj;
                            String name;
                            if(event.getRecurrenceNumber() != null)
                                name = "EVENT"+event.getEvent().getId()+"."+event.getRecurrenceNumber();
                            else
                                name = "EVENT" + event.getEvent().getId();
                            if(alarmEntry.getName().equals(name)){
                                if(log.isDebugEnabled())
                                    log.debug("removing mail job for: " + event);
                                manager.getAlarmManager().removeAlarm(alarmEntry);
                            }
                        }
                        try
                        {
                            if(log.isInfoEnabled())
                                log.info("adding mailJob for: " + event);
                            String name;
                            if(event.getRecurrenceNumber() != null)
                                name = "EVENT"+event.getEvent().getId()+"."+event.getRecurrenceNumber();
                            else
                                name = "EVENT" + event.getEvent().getId();
                            AlarmEntry alarmEntry = new AlarmEntry(name,event.getReminderDate(),mailJob);
                            alarmEntry.setRingInNewThead();
                            manager.getAlarmManager().addAlarm(alarmEntry);
                        }
                        catch (PastDateException e)
                        {
                            if(log.isInfoEnabled())
                                log.info("ignoring old event alarm: " + event);
                        }
                    }catch(NoValidSenderException e)
                    {
                        log.warn("no person for user: " + user);
                    }
                }
                else
                {
                    if(log.isInfoEnabled())
                        log.info("no reminder date of old reminder date for: " + event);
                }
            }
            
            List<JobVO> jobs = new JobDAO().getByUser(user, startDate, endDate);
            if(log.isDebugEnabled())
                log.debug(jobs.size() + " job jobs found");
            for(JobVO job : jobs)
            {
                if(log.isDebugEnabled())
                    log.debug("generating jobs for job: " + job);
                
                JobReminderMail reminderMail;
                try
                {
                    reminderMail = new JobReminderMail();
                }
                catch (AddressException e1)
                {
                    log.warn("cannot create reminder mail, incorrect sender address",e1);
                    return;
                }
                reminderMail.setJob(job);
                try
                {
                    reminderMail.setUser(user);


                
                    MailJob mailJob = new MailJob(reminderMail);
                    
                    for(Object obj :  manager.getAlarmManager().getAllAlarms())
                    {
                        AlarmEntry alarmEntry = (AlarmEntry) obj;
                        if(alarmEntry.getName().equals("EVENT"+job.getId())){

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.