View Javadoc

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   * *** Centre de Calcul de l'IN2P3 - Lyon (France) ***
16   * ***             http://cc.in2p3.fr/             ***
17   * ***************************************************
18   * File:   AbstractAsyncJobFactoryImpl
19   * Author: Sylvain Reynaud (sreynaud@in2p3.fr)
20   * Date:   5 juin 2009
21   * ***************************************************
22   * Description:                                      */
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  }