* Example:
* Trx.run(null, new {@link TrxRunnable}() {
* public void run(String trxName) {
* // do something using trxName
* }
* )};
*
*
* @param trxName transaction name (if null, a new transaction will be created)
* @param r runnable object
* @throws RuntimeException or {@link AdempiereException}
*/
public static void run(String trxName, TrxRunnable r)
{
boolean localTrx = false;
if (trxName == null) {
trxName = Trx.createTrxName("TrxRun");
localTrx = true;
}
Trx trx = Trx.get(trxName, true);
Savepoint savepoint = null;
try
{
if (!localTrx)
savepoint = trx.setSavepoint(null);
r.run(trxName);
if (localTrx)
trx.commit(true);
}
catch (Throwable e)
{
// Rollback transaction
if (localTrx)
{
trx.rollback();
}
else if (savepoint != null)
{
try {
trx.rollback(savepoint);
}
catch (SQLException e2) {;}
}
// Throw exception
if (e instanceof RuntimeException)
{
throw (RuntimeException)e;
}
else
{
throw new AdempiereException(e);
}
}
finally {
if (localTrx && trx != null)
{
trx.close();
trx = null;
}
}
}
/**
* Get transaction time out value
* @return transaction time out value in second
*/
public int getTimeout() {
return m_timeout;
}
/**
* set transaction timeout value ( in seconds )
* @param timeout
*/
public void setTimeout(int timeout) {
m_timeout = timeout;
}
/**
* Add transaction event listener
* @param listener
*/
public void addTrxEventListener(TrxEventListener listener) {
listeners.add(listener);
}
/**
* Remove transaction event listener
* @param listener
* @return true if listener is found and remove
*/
public boolean removeTrxEventListener(TrxEventListener listener) {
return listeners.remove(listener);
}
/**
* Get stack trace save
* @return stack trace save or empty string
*/
public String getStrackTrace()
{
if (trace != null)
{
StringWriter stringWriter = new StringWriter();
PrintWriter printWriter = new PrintWriter(stringWriter);
trace.printStackTrace(printWriter);
return stringWriter.getBuffer().toString();
}
else
{
return "";
}
}
/**
* Get transaction display name. Fall back to transaction name if display name is not set.
* @return display name or name
*/
public String getDisplayName()
{
return m_displayName != null ? m_displayName : m_trxName;
}
/**
* Set transaction display name
* @param displayName
*/
public void setDisplayName(String displayName)
{
m_displayName = displayName;
}
/**
* Indicate additional DB changes have been made by a transaction event listener
* @param changesMade
*/
public void setChangesMadeByEventListener(boolean changesMade)
{
m_changesMadeByEventListener = changesMade;
}
/**
* Is there additional changes make by transaction event listener
* @return true if event listener(s) has flag that additional DB changes have been made
*/
public boolean hasChangesMadeByEventListener()
{
return m_changesMadeByEventListener;
}
/** Transaction timeout monitor class */
public static class TrxMonitor implements Runnable
{
@Override
public void run()
{
if (!Trx.s_cache.isEmpty())
{
Trx[] trxs = Trx.s_cache.values().toArray(new Trx[0]);
for(int i = 0; i < trxs.length; i++)
{
if (trxs[i].m_startTime <= 0)
continue;
long since = System.currentTimeMillis() - trxs[i].m_startTime;
if (since > trxs[i].getTimeout() * 1000)
{
trxs[i].log.log(Level.WARNING, "Transaction timeout. Name="+trxs[i].getTrxName() + ", timeout(sec)="+(since / 1000));
if (trxs[i].trace != null)
{
trxs[i].log.log(Level.WARNING, "Transaction timeout. Trace:\n" + trxs[i].getStrackTrace());
}
trxs[i].rollbackAndCloseOnTimeout();
}
}
}
}
}
/**
* Is trxName a PO local transaction ?
* @param trxName
* @return true if trxName is a PO local transaction
*/
private boolean isLocalTrx(String trxName)
{
return trxName == null
|| trxName.startsWith(PO.LOCAL_TRX_PREFIX);
}
@Override
protected void finalize() throws Throwable {
if (m_connection != null && trace != null) {
final Trx me = this;
Adempiere.getThreadPoolExecutor().schedule(new Runnable() {
@Override
public void run() {
if (me.m_connection != null && me.trace != null) {
log.log(Level.WARNING, "Trx Not Close: " + me.getStrackTrace());
me.trace = null;
me.close();
}
}
}, 2, TimeUnit.SECONDS);
}
}
/**
* Register a null trx
* @return
*/
public static String registerNullTrx() {
String nullTrxName = "NullTrx_" + UUID.randomUUID().toString();
Trx nullTrx = new Trx(nullTrxName);
nullTrx.trace = new Exception();
nullTrx.m_startTime = System.currentTimeMillis();
String displayName = null;
StackWalker walker = StackWalker.getInstance(StackWalker.Option.RETAIN_CLASS_REFERENCE);
Optional