<p>
Add the given <code>{@link com.helger.quartz.IJobListener}</code> to the
<code>Scheduler</code>'s <i>internal</i> list.
</p>
352760
public void addInternalJobListener (final IJobListener jobListener)
  {
    ValueEnforcer.notNull (jobListener, "JobListener");
    ValueEnforcer.notEmpty (jobListener.getName (), "JobListener.getName()");

    synchronized (m_aInternalJobListeners)
    {
      m_aInternalJobListeners.put (jobListener.getName (), jobListener);
    }
  }
752714
public void add(final GridmixJob job) throws InterruptedException {
    final boolean addToQueue = !shutdown;
    if (addToQueue) {
      final SubmitTask task = new SubmitTask(job);
      sem.acquire();
      try {
        sched.execute(task);
      } catch (RejectedExecutionException e) {
        sem.release();
      }
    }
  }
62992
public void setSchedules(java.util.Collection<Schedule> schedules) {
        if (schedules == null) {
            this.schedules = null;
            return;
        }

        this.schedules = new java.util.ArrayList<Schedule>(schedules);
    }
79362
public Date rescheduleJob (final TriggerKey triggerKey, final ITrigger newTrigger) throws SchedulerException
  {
    return m_aSched.rescheduleJob (triggerKey, newTrigger);
  }
738674
public void addJobFromConfiguration(CmsScheduledJobInfo jobInfo) {

        m_configuredJobs.add(jobInfo);

        if (CmsLog.INIT.isInfoEnabled()) {
            CmsLog.INIT.info(
                Messages.get().getBundle().key(
                    Messages.INIT_SCHEDULER_CONFIG_JOB_3,
                    jobInfo.getJobName(),
                    jobInfo.getClassName(),
                    jobInfo.getContextInfo().getUserName()));
        }
    }
62864
private void makeJobRunning(JobInProgress job, JobSchedulingInfo oldInfo, 
                              QueueInfo qi) {
    // Removing of the job from job list is responsibility of the
    //initialization poller.
    // Add the job to the running queue
    qi.addRunningJob(job);
  }
988691
@Override
  public List<Trigger> getTriggersOfJob(String jobKey) throws SchedulerException {

    validateState();

    return quartzSchedulerResources.getJobStore().getTriggersForJob(jobKey);
  }
1082520
void put(final AbstractBatchEntry batchEntry) {
    try {
        this.queue.put(batchEntry);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
    if (this.queue.size() >= this.actions) {
      this.scheduler.submit(new Runnable() {
        @Override
        public void run() {
          write();
        }
      });
    }
  }
829372
synchronized void jobAdded(JobInProgress job) throws IOException {
    QueueSchedulingInfo qsi = 
      queueInfoMap.get(job.getProfile().getQueueName());
    // qsi shouldn't be null
    // update user-specific info
    Integer i = qsi.numJobsByUser.get(job.getProfile().getUser());
    if (null == i) {
      i = 1;
      // set the count for running tasks to 0
      qsi.mapTSI.numSlotsOccupiedByUser.put(job.getProfile().getUser(),
          Integer.valueOf(0));
      qsi.reduceTSI.numSlotsOccupiedByUser.put(job.getProfile().getUser(),
          Integer.valueOf(0));
    }
    else {
      i++;
    }
    qsi.numJobsByUser.put(job.getProfile().getUser(), i);
    
    // setup scheduler specific job information
    preInitializeJob(job);
    
    LOG.debug("Job " + job.getJobID().toString() + " is added under user " 
              + job.getProfile().getUser() + ", user now has " + i + " jobs");
  }
593771
public void add (Schedulable schedulable, int frequency, int phase, float priority) {
		// Compile the record and add it to the list
		schedulableRecords.add(new PrioritySchedulableRecord(schedulable, frequency, phase, priority));
	}
1249101
public void addListener(final ORecordListener iListener) {
    if (_listeners == null)
      _listeners = Collections.newSetFromMap(new WeakHashMap<ORecordListener, Boolean>());

    _listeners.add(iListener);
  }
972038
private synchronized void internalSchedule(final Schedule s) {
    this.scheduleIDMap.put(s.getScheduleId(), s);
    this.scheduleIdentityPairMap.put(s.getScheduleIdentityPair(), s);
  }
812666
public void setJobQueues(java.util.Collection<String> jobQueues) {
        if (jobQueues == null) {
            this.jobQueues = null;
            return;
        }

        this.jobQueues = new java.util.ArrayList<String>(jobQueues);
    }
830440
protected void addListeningIterator(IClockwiseIterator iterator) {
		if (this.listeningIterators == null) {
			this.listeningIterators = new WeakArrayList<>();
		}
		this.listeningIterators.add(iterator);
	}
1295244
@Override
	public void addWithAutomaticPhasing (Schedulable schedulable, int frequency) {
		// Calculate the phase and add the schedulable to the list
		add(schedulable, frequency, calculatePhase(frequency));
	}
275525
public void scheduleJobs(Scheduler sched) throws SchedulerException {

    List<JobDetail> jobs = new LinkedList<JobDetail>(getLoadedJobs());
    List<OperableTrigger> triggers = new LinkedList<OperableTrigger>(getLoadedTriggers());

    logger.info("Adding " + jobs.size() + " jobs, " + triggers.size() + " triggers.");

    for (JobDetail jobDetail : jobs) {
      logger.info("Scheduled job: {} ", jobDetail);

      sched.addJob(jobDetail);
    }

    for (OperableTrigger trigger : triggers) {

      logger.info("Scheduled trigger: {}", trigger);

      if (trigger.getStartTime() == null) {
        trigger.setStartTime(new Date());
      }

      Trigger dupeT = sched.getTrigger(trigger.getName());
      if (dupeT != null) { // if trigger with name already exists

        if (!dupeT.getJobName().equals(trigger.getJobName())) {
          logger.warn(
              "Possibly duplicately named ({}) triggers in jobs xml file! ", trigger.getName());
        }

        sched.rescheduleJob(trigger.getName(), trigger);
      } else {
        logger.debug(
            "Scheduling job: " + trigger.getJobName() + " with trigger: " + trigger.getName());

        try {
          sched.scheduleJob(trigger);
        } catch (ObjectAlreadyExistsException e) {
          logger.debug(
              "Adding trigger: "
                  + trigger.getName()
                  + " for job: "
                  + trigger.getJobName()
                  + " failed because the trigger already existed.");
        }
      }
    }
  }
499918
@Inject
    public void schedule( Scheduler scheduler )
        throws Exception
    {
        if ( cronExpression == null && trigger == null )
        {
            throw new ProvisionException( format( "Impossible to schedule Job '%s' without cron expression",
                                                  jobClass.getName() ) );
        }
        if ( cronExpression != null && trigger != null )
        {
          throw new ProvisionException( format( "Impossible to schedule Job '%s' with cron expression " +
                                                "and an associated Trigger at the same time", jobClass.getName() ) );
        }

        JobKey jobKey = jobKey( DEFAULT.equals( jobName ) ? jobClass.getName() : jobName, jobGroup );
        TriggerKey triggerKey = triggerKey( DEFAULT.equals( triggerName ) ? jobClass.getCanonicalName() : triggerName, triggerGroup );

        if ( updateExistingTrigger && scheduler.checkExists( triggerKey ) ) {
            scheduler.unscheduleJob( triggerKey );
        }

        scheduler.scheduleJob( newJob( jobClass )
                               .withIdentity( jobKey )
                               .requestRecovery( requestRecovery )
                               .storeDurably( storeDurably ).build(),
                               ( trigger == null ) ?
                               newTrigger()
                               .withIdentity( triggerKey )
                               .withSchedule( cronSchedule( cronExpression )
                                              .inTimeZone( timeZone ) )
                                              .withPriority( priority )
                                              .build()
                                : trigger);
    }