1 package fr.in2p3.jsaga.impl.job;
2
3 import fr.in2p3.jsaga.engine.factories.JobAdaptorFactory;
4 import fr.in2p3.jsaga.engine.factories.JobMonitorAdaptorFactory;
5 import fr.in2p3.jsaga.impl.task.AbstractThreadedTask;
6 import org.ogf.saga.error.*;
7 import org.ogf.saga.job.JobFactory;
8 import org.ogf.saga.job.JobService;
9 import org.ogf.saga.session.Session;
10 import org.ogf.saga.task.Task;
11 import org.ogf.saga.task.TaskMode;
12 import org.ogf.saga.url.URL;
13
14
15
16
17
18
19
20
21
22
23
24
25
26 public abstract class AbstractAsyncJobFactoryImpl extends AbstractSyncJobFactoryImpl {
27 public AbstractAsyncJobFactoryImpl(JobAdaptorFactory adaptorFactory, JobMonitorAdaptorFactory monitorAdaptorFactory) {
28 super(adaptorFactory, monitorAdaptorFactory);
29 }
30
31 protected Task<JobFactory, JobService> doCreateJobService(TaskMode mode, final Session session, final URL rm) throws NotImplementedException {
32 return new AbstractThreadedTask<JobFactory,JobService>(mode) {
33 public JobService invoke() throws NotImplementedException, IncorrectURLException, AuthenticationFailedException, AuthorizationFailedException, PermissionDeniedException, BadParameterException, IncorrectStateException, AlreadyExistsException, DoesNotExistException, TimeoutException, NoSuccessException {
34 return AbstractAsyncJobFactoryImpl.super.doCreateJobServiceSync(session, rm);
35 }
36 };
37 }
38 }