| 0,0 → 1,151 |
|---|
| /* |
| * Copyright 2011 Brian Rosenberger (Brutex Network) |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| package net.brutex.xservices.ws.impl; |
| |
| import static org.quartz.TriggerBuilder.newTrigger; |
| |
| import java.util.ArrayList; |
| import java.util.GregorianCalendar; |
| import java.util.List; |
| import java.util.Set; |
| import java.util.TimeZone; |
| import java.util.UUID; |
| |
| import javax.jws.WebService; |
| |
| import org.quartz.JobBuilder; |
| import org.quartz.JobDataMap; |
| import org.quartz.JobDetail; |
| import org.quartz.JobKey; |
| import org.quartz.Scheduler; |
| import org.quartz.SchedulerException; |
| import org.quartz.SimpleTrigger; |
| import org.quartz.Trigger; |
| import org.quartz.TriggerKey; |
| import org.quartz.impl.StdSchedulerFactory; |
| import org.quartz.impl.matchers.GroupMatcher; |
| |
| import net.brutex.xservices.types.ScheduledJob; |
| import net.brutex.xservices.util.BrutexNamespaces; |
| import net.brutex.xservices.util.JobWrapper; |
| import net.brutex.xservices.ws.JobService; |
| import net.brutex.xservices.ws.XServicesFault; |
| |
| /** |
| * @author Brian Rosenberger |
| * @since 0.5.0 |
| * |
| */ |
| @WebService(targetNamespace = BrutexNamespaces.WS_XSERVICES, endpointInterface = "net.brutex.xservices.ws.JobService", serviceName = JobService.SERVICE_NAME) |
| public class JobServiceImpl implements JobService { |
| |
| |
| public List<ScheduledJob> getJobList() throws XServicesFault { |
| List<ScheduledJob> joblist = new ArrayList<ScheduledJob>(); |
| try { |
| Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); |
| List<String> jobgroups = scheduler.getJobGroupNames(); |
| for (String g : jobgroups) { |
| GroupMatcher m = GroupMatcher.groupContains(g); |
| Set<JobKey> keyset = scheduler.getJobKeys(m); |
| for (JobKey key : keyset) { |
| JobDataMap detail = scheduler.getJobDetail(key) |
| .getJobDataMap(); |
| ScheduledJob job = new ScheduledJob(key.getName(), |
| (GregorianCalendar) detail.get("date"), |
| detail.getString("script")); |
| joblist.add(job); |
| } |
| |
| } |
| |
| } catch (SchedulerException e) { |
| throw new XServicesFault(e); |
| } |
| return joblist; |
| } |
| |
| |
| public ScheduledJob getJob(String uuid) throws XServicesFault { |
| try { |
| Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); |
| JobDetail job = scheduler.getJobDetail(new JobKey(uuid, "DEFAULT")); |
| if (job == null) |
| throw new XServicesFault("Job not found."); |
| Trigger t = scheduler.getTrigger(new TriggerKey(uuid)); |
| GregorianCalendar cal = new GregorianCalendar(TimeZone.getDefault()); |
| cal.setTime(t.getStartTime()); |
| return new ScheduledJob(uuid, cal, job.getJobDataMap().getString( |
| "script"), job.getDescription()); |
| } catch (SchedulerException e) { |
| e.printStackTrace(); |
| throw new XServicesFault(e); |
| } |
| } |
| |
| |
| public void deleteJob(String uuid) throws XServicesFault { |
| try { |
| Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); |
| JobKey key = new JobKey(uuid, "DEFAULT"); |
| JobDetail job = scheduler.getJobDetail(key); |
| if (job == null) |
| throw new XServicesFault("Job not found."); |
| Trigger t = scheduler.getTrigger(new TriggerKey(uuid)); |
| scheduler.deleteJob(key); |
| } catch (SchedulerException e) { |
| throw new XServicesFault(e); |
| } |
| |
| } |
| |
| |
| public String scheduleJob(ScheduledJob job) throws XServicesFault { |
| try { |
| // Grab the Scheduler instance from the Factory |
| Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); |
| |
| // and start it off |
| |
| if (!scheduler.isStarted()) |
| scheduler.start(); |
| if (scheduler.isInStandbyMode()) |
| scheduler.resumeAll(); |
| |
| String identity = UUID.randomUUID().toString(); |
| //String identity = "test"; |
| JobDetail job2 = JobBuilder.newJob(JobWrapper.class) |
| .withIdentity(identity).build(); |
| |
| |
| job2.getJobDataMap().put("script", job.getScript()); |
| job2.getJobDataMap().put("description", job.getDescription()); |
| job2.getJobDataMap().put("date", job.getDate()); |
| |
| SimpleTrigger t = (SimpleTrigger) newTrigger() |
| .withIdentity(identity).startAt(job.getDate().getTime()) |
| .build(); |
| ; |
| |
| scheduler.scheduleJob(job2, t); |
| return identity; |
| } catch (SchedulerException e) { |
| e.printStackTrace(); |
| throw new XServicesFault(e); |
| } |
| } |
| |
| } |
| Property changes: |
|---|
| Added: svn:mime-type |
|---|
| +text/plain |
|---|
| \ No newline at end of property |
|---|