[ 1898042 ] VPN/Wan transaction management bugs

This commit is contained in:
Heng Sin Low 2008-02-20 17:14:53 +00:00
parent 0b4e764f46
commit c1b14374e1
1 changed files with 32 additions and 14 deletions

View File

@ -213,7 +213,10 @@ public class Trx implements VetoableChangeListener
{ // See ServerBean { // See ServerBean
server.startTransaction(getTrxName()); server.startTransaction(getTrxName());
} }
log.log(Level.WARNING, "AppsServer not found"); else
{
log.log(Level.WARNING, "AppsServer not found");
}
} }
catch (RemoteException ex) catch (RemoteException ex)
{ {
@ -327,10 +330,13 @@ public class Trx implements VetoableChangeListener
{ // See ServerBean { // See ServerBean
return server.rollback(m_trxName); return server.rollback(m_trxName);
} }
log.log(Level.SEVERE, "AppsServer not found"); else
if (throwException) {
throw new SQLException("AppsServer not found"); log.log(Level.SEVERE, "AppsServer not found");
return false; if (throwException)
throw new SQLException("AppsServer not found");
return false;
}
} }
catch (RemoteException ex) catch (RemoteException ex)
{ {
@ -375,8 +381,11 @@ public class Trx implements VetoableChangeListener
sp = new SavepointVO(savepoint); sp = new SavepointVO(savepoint);
return server.rollback(m_trxName, sp); return server.rollback(m_trxName, sp);
} }
log.log(Level.SEVERE, "AppsServer not found"); else
throw new SQLException("AppsServer not found"); {
log.log(Level.SEVERE, "AppsServer not found");
throw new SQLException("AppsServer not found");
}
} }
catch (RemoteException ex) catch (RemoteException ex)
{ {
@ -449,10 +458,13 @@ public class Trx implements VetoableChangeListener
{ // See ServerBean { // See ServerBean
return server.commit(m_trxName); return server.commit(m_trxName);
} }
log.log(Level.SEVERE, "AppsServer not found"); else
if (throwException) {
throw new SQLException("AppsServer not found"); log.log(Level.SEVERE, "AppsServer not found");
return false; if (throwException)
throw new SQLException("AppsServer not found");
return false;
}
} }
catch (RemoteException ex) catch (RemoteException ex)
{ {
@ -540,7 +552,10 @@ public class Trx implements VetoableChangeListener
{ // See ServerBean { // See ServerBean
server.closeTransaction(getTrxName()); server.closeTransaction(getTrxName());
} }
log.log(Level.WARNING, "AppsServer not found"); else
{
log.log(Level.WARNING, "AppsServer not found");
}
} }
catch (RemoteException ex) catch (RemoteException ex)
{ {
@ -580,8 +595,11 @@ public class Trx implements VetoableChangeListener
{ // See ServerBean { // See ServerBean
return server.setSavepoint(m_trxName, name); return server.setSavepoint(m_trxName, name);
} }
log.log(Level.SEVERE, "AppsServer not found"); else
throw new SQLException("AppsServer not found"); {
log.log(Level.SEVERE, "AppsServer not found");
throw new SQLException("AppsServer not found");
}
} }
catch (RemoteException ex) catch (RemoteException ex)
{ {