public class JTAJobRunShell extends JobRunShell
An extension of
that
begins an XA transaction before executing the Job, and commits (or
rolls-back) the transaction after execution completes.
JobRunShell
JobRunShell
firedTriggerBundle, jec, qs, scheduler, shutdownRequested
Constructor and Description |
---|
JTAJobRunShell(Scheduler scheduler,
TriggerFiredBundle bndle)
Create a JTAJobRunShell instance with the given settings.
|
JTAJobRunShell(Scheduler scheduler,
TriggerFiredBundle bndle,
int timeout)
Create a JTAJobRunShell instance with the given settings.
|
Modifier and Type | Method and Description |
---|---|
protected void |
begin() |
protected void |
complete(boolean successfulExecution) |
void |
passivate()
Override passivate() to ensure we always cleanup the UserTransaction.
|
getLog, initialize, requestShutdown, run, schedulerShuttingdown
jobAdded, jobDeleted, jobPaused, jobResumed, jobScheduled, jobsPaused, jobsResumed, jobUnscheduled, schedulerError, schedulerInStandbyMode, schedulerShutdown, schedulerStarted, schedulerStarting, schedulingDataCleared, triggerFinalized, triggerPaused, triggerResumed, triggersPaused, triggersResumed
public JTAJobRunShell(Scheduler scheduler, TriggerFiredBundle bndle)
Create a JTAJobRunShell instance with the given settings.
public JTAJobRunShell(Scheduler scheduler, TriggerFiredBundle bndle, int timeout)
Create a JTAJobRunShell instance with the given settings.
protected void begin() throws SchedulerException
begin
in class JobRunShell
SchedulerException
protected void complete(boolean successfulExecution) throws SchedulerException
complete
in class JobRunShell
SchedulerException
public void passivate()
passivate
in class JobRunShell
Copyright 2001-2019, Terracotta, Inc.