Package org.pentaho.platform.api.scheduler2

Examples of org.pentaho.platform.api.scheduler2.IJobFilter

331
332
333
334
335
336
337
338
339
340
341
  }

  @Test
  public void testGetContentCleanerJobException() throws Exception {

    IJobFilter jobFilter = mock( IJobFilter.class );

    List<Job> jobs = new ArrayList<Job>();

    IPentahoSession session = mock( IPentahoSession.class );
    doReturn( session ).when( schedulerService ).getSession();
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
    listener.setFakeAvail(); // Fake availability of version checker.
    listener.startup( testSession );

    IScheduler scheduler = PentahoSystem.get( IScheduler.class, "IScheduler2", null ); //$NON-NLS-1$
    IJobFilter filter = new IJobFilter() {
      public boolean accept( Job job ) {
        return job.getJobName().contains( "PentahoSystemVersionCheck" );
      }
    };
    List<Job> matchingJobs = scheduler.getJobs( filter );
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
    Job[] serviceJobs = schedulerSvc.getJobs();

    //
    // First make sure the actual scheduler engine can find the newly created job
    //
    List<Job> engineJobs = scheduler.getJobs( new IJobFilter() {
      public boolean accept( Job job ) {
        return job.getJobName().contains( "testGetJobsJob" );
      }
    } );
    Assert.assertEquals( "The scheduler engine does not know about the job.", 1, engineJobs.size() );
View Full Code Here
124
125
126
127
128
129
130
131
132
133
134
      }
    }

    Job job = null;

    IJobTrigger jobTrigger = SchedulerResourceUtil.convertScheduleRequestToJobTrigger( scheduleRequest, scheduler );

    HashMap<String, Serializable> parameterMap = new HashMap<String, Serializable>();
    for ( JobScheduleParam param : scheduleRequest.getJobParameters() ) {
      parameterMap.put( param.getName(), param.getValue() );
    }
View Full Code Here
378
379
380
381
382
383
384
385
386
387
388
    }
    throw new IllegalArgumentException();
  }

  public BlockStatusProxy getBlockStatus( JobScheduleRequest jobScheduleRequest ) throws SchedulerException {
    IJobTrigger trigger = convertScheduleRequestToJobTrigger( jobScheduleRequest );
    Boolean totallyBlocked = false;
    Boolean partiallyBlocked = getBlockoutManager().isPartiallyBlocked( trigger );
    if ( partiallyBlocked ) {
      totallyBlocked = !getBlockoutManager().willFire( trigger );
    }
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
    boolean runInBackground =
        scheduleRequest.getSimpleJobTrigger() == null && scheduleRequest.getComplexJobTrigger() == null
            && scheduleRequest.getCronJobTrigger() == null;

    // add 10 seconds to the RIB to ensure execution (see PPP-3264)
    IJobTrigger jobTrigger =
        runInBackground ? new SimpleJobTrigger( new Date( System.currentTimeMillis() + 10000 ), null, 0, 0 ) : scheduleRequest.getSimpleJobTrigger();

    if ( scheduleRequest.getSimpleJobTrigger() != null ) {
      SimpleJobTrigger simpleJobTrigger = scheduleRequest.getSimpleJobTrigger();
View Full Code Here
758
759
760
761
762
763
764
765
766
767
768
  @Test
  public void testBlockoutWillFire() throws Exception {
    JobScheduleRequest mockJobScheduleRequest = mock( JobScheduleRequest.class );

    IJobTrigger mockJobTrigger = mock( IJobTrigger.class );
    doReturn( mockJobTrigger ).when( schedulerResource ).convertScheduleRequestToJobTrigger( mockJobScheduleRequest );

    Boolean willFire = Boolean.FALSE;
    doReturn( willFire ).when( schedulerResource.schedulerService ).willFire( mockJobTrigger );
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
49
  @Override
  public IJobTrigger getBlockOut( String blockOutJobId ) {
    try {
      Job blockOutJob = this.scheduler.getJob( blockOutJobId );
      IJobTrigger blockOutJobTrigger = blockOutJob.getJobTrigger();
      blockOutJobTrigger.setDuration( ( (Number) blockOutJob.getJobParams().get( DURATION_PARAM ) ).longValue() );
      return blockOutJobTrigger;
    } catch ( SchedulerException e ) {
      throw new RuntimeException( e );
    }
  }
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
68
    return true;
  }

  private void scheduleJob( int intervalInSeconds ) throws Exception {

    IScheduler scheduler = PentahoSystem.get( IScheduler.class, "IScheduler2", null ); //$NON-NLS-1$
    JobTrigger trigger = new SimpleJobTrigger( new Date(), null, -1, intervalInSeconds );

    jobMap.put( "transFileName", getTransFileName() );
    scheduler.createJob( GatherStatsListener.JOB_NAME, GatherStatsAction.class, jobMap, trigger );
    logger.info( "Statistics gathering jop has been scheduled." );
  }
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
    return versionRequestFlags;
  }

  protected void scheduleJob( final int versionRequestFlags, final int repeatSeconds ) throws Exception {

    IScheduler scheduler = PentahoSystem.get( IScheduler.class, "IScheduler2", null ); //$NON-NLS-1$

    deleteJobIfNecessary();

    Map<String, Serializable> parms = new HashMap<String, Serializable>();
    parms.put( VersionCheckerAction.VERSION_REQUEST_FLAGS, new Integer( versionRequestFlags ) );
    JobTrigger trigger = new SimpleJobTrigger( new Date(), null, -1, repeatSeconds );
    scheduler.createJob( EmbeddedVersionCheckSystemListener.VERSION_CHECK_JOBNAME, VersionCheckerAction.class, parms,
        trigger );
  }
View Full Code Here
TOP

Related Classes of org.pentaho.platform.api.scheduler2.IJobFilter

  • org.pentaho.platform.admin.GatherStatsListener
  • org.pentaho.platform.scheduler2.blockout.BlockoutManagerUtil
  • org.pentaho.platform.scheduler2.blockout.PentahoBlockoutManager
  • org.pentaho.platform.scheduler2.blockout.PentahoBlockoutManagerTest
  • org.pentaho.platform.scheduler2.quartz.ActionAdapterQuartzJob
  • org.pentaho.platform.scheduler2.quartz.QuartzJobKey
  • org.pentaho.platform.scheduler2.quartz.QuartzScheduler
  • org.pentaho.platform.scheduler2.quartz.test.ComplexTriggerTest
  • org.pentaho.platform.scheduler2.quartz.test.QuartzSchedulerTest
  • org.pentaho.platform.scheduler2.quartz.test.SimpleTriggerTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.