Package net.sf.basedb.opengrid

Class AbortJobIfTransactionFails

java.lang.Object

net.sf.basedb.opengrid.AbortJobIfTransactionFails

All Implemented Interfaces:

TransactionalAction

public class AbortJobIfTransactionFails
extends Object
implements TransactionalAction

When a job has been submitted to the cluster the job-id and other information has to be registered in BASE. But if the registration fails there is no need to keep the job in the queue on the cluster so we try to delete it.

Since:

1.0

Author:

nicklas

Field Summary

Fields

Modifier and Type	Field	Description
private final JobIdentifier	jobId
private static final ExtensionsLogger	logger

Constructor Summary

Constructors

Constructor	Description
AbortJobIfTransactionFails(JobIdentifier jobId)

Method Summary

Modifier and Type	Method	Description
void	onAfterCommit()
void	onBeforeCommit()
void	onRollback()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

private static final ExtensionsLogger logger

jobId

private final JobIdentifier jobId

Constructor Details

AbortJobIfTransactionFails

public AbortJobIfTransactionFails(JobIdentifier jobId)

Method Details

onAfterCommit

public void onAfterCommit()

Specified by:

onAfterCommit in interface TransactionalAction

onBeforeCommit

public void onBeforeCommit()

Specified by:

onBeforeCommit in interface TransactionalAction

onRollback

public void onRollback()

Specified by:

onRollback in interface TransactionalAction