List of recoverIncompleteTx() Examples

Examples of recoverIncompleteTx()

com.sun.enterprise.resource.ResourceInstaller.recoverIncompleteTx()
com.sun.enterprise.transaction.api.ResourceRecoveryManager.recoverIncompleteTx()
recover incomplete transactions @param delegated indicates whether delegated recovery is needed @param logPath transaction log directory path @return boolean indicating the status of transaction recovery @throws Exception when unable to recover

Examples of com.sun.enterprise.resource.ResourceInstaller.recoverIncompleteTx()

                String txLogDir=(String)(signal.getMemberDetails().get(TXLOGDIR));
                if (logger.isLoggable(Level.FINE))
                    logger.log(Level.FINE,sm.getString("enterprise_autotxrecovery.tx_logdir",txLogDir,failedInstance));
                if (logger.isLoggable(Level.FINE))
                    logger.log(Level.FINE,sm.getString("enterprise_autotxrecovery.starting_recovery",failedInstance));
                result = resInstaller.recoverIncompleteTx(true, txLogDir);
                if (logger.isLoggable(Level.FINE))
                    logger.log(Level.FINE,sm.getString("enterprise_autotxrecovery.recovery_completed",failedInstance));   
                if (result) {
                    // If we have successfully recovered transactions for
                    // the failed instance, initiate EJB Timer migration

View Full Code Here

Examples of com.sun.enterprise.resource.ResourceInstaller.recoverIncompleteTx()

        boolean result = true;
        if (resInstaller == null) {
            throw new IllegalStateException();
        }
        if (!delegated) { // own recovery
            result = resInstaller.recoverIncompleteTx(false, null);
        }
        else { // delegated recovery
            result = resInstaller.recoverIncompleteTx(true, txLogDir);
        }
        if (!result)

View Full Code Here

Examples of com.sun.enterprise.resource.ResourceInstaller.recoverIncompleteTx()

        }
        if (!delegated) { // own recovery
            result = resInstaller.recoverIncompleteTx(false, null);
        }
        else { // delegated recovery
            result = resInstaller.recoverIncompleteTx(true, txLogDir);
        }
        if (!result)
            throw new IllegalStateException();
    }

View Full Code Here

Examples of com.sun.enterprise.transaction.api.ResourceRecoveryManager.recoverIncompleteTx()

                            _logger.log(Level.FINE, "Incomplete transaction recovery is "
                                    + "not required,  waiting for the next interval SIZE");
                       continue;
                    }
                    prevSize = RecoveryManager.sizeOfInCompleTx();
                    recoveryManager.recoverIncompleteTx(false, null);
                }
            } catch (Exception ex) {
                if (_logger.isLoggable(Level.FINE))
                    _logger.log(Level.FINE, " Exception occurred in recoverInCompleteTx ");
            }

View Full Code Here

Examples of com.sun.enterprise.transaction.api.ResourceRecoveryManager.recoverIncompleteTx()

                            _logger.log(Level.FINE, "Incomplete transaction recovery is "
                                    + "not required,  waiting for the next interval SIZE");
                       continue;
                    }
                    prevSize = RecoveryManager.sizeOfInCompleTx();
                    recoveryManager.recoverIncompleteTx(false, null);
                }
            } catch (Exception ex) {
                if (_logger.isLoggable(Level.FINE))
                    _logger.log(Level.FINE, " Exception occurred in recoverInCompleteTx ");
            }

View Full Code Here

Examples of com.sun.enterprise.transaction.api.ResourceRecoveryManager.recoverIncompleteTx()

                _logger.log(Level.FINE, "Transaction log directory for " + instance + " is " + logdir);
                _logger.log(Level.FINE, "Starting transaction recovery of " + instance);
            }


            ResourceRecoveryManager recoveryManager = habitat.getComponent(ResourceRecoveryManager.class);
            recoveryManager.recoverIncompleteTx(true, logdir, instance, true);
            if (_logger.isLoggable(Level.FINE)) {
                _logger.log(Level.FINE, "Transaction recovery of " + instance + " is completed");
            }
        } catch (Throwable e) {
            _logger.log(Level.WARNING, "jts.recovery_error", e);

View Full Code Here

Examples of com.sun.enterprise.transaction.api.ResourceRecoveryManager.recoverIncompleteTx()

                            _logger.log(Level.FINE, "Incomplete transaction recovery is "
                                    + "not required,  waiting for the next interval SIZE");
                       continue;
                    }
                    prevSize = RecoveryManager.sizeOfInCompleteTx();
                    recoveryManager.recoverIncompleteTx(false, null);
                }
            } catch (Exception ex) {
                if (_logger.isLoggable(Level.FINE))
                    _logger.log(Level.FINE, " Exception occurred in recoverInCompleteTx ");
            }

View Full Code Here

Examples of com.sun.enterprise.transaction.api.ResourceRecoveryManager.recoverIncompleteTx()

                            _logger.log(Level.FINE, "Incomplete transaction recovery is "
                                    + "not required,  waiting for the next interval SIZE");
                       continue;
                    }
                    prevSize = RecoveryManager.sizeOfInCompleteTx();
                    recoveryManager.recoverIncompleteTx(false, null);
                }
            } catch (Exception ex) {
                if (_logger.isLoggable(Level.FINE))
                    _logger.log(Level.FINE, " Exception occurred in recoverInCompleteTx ");
            }

View Full Code Here

Examples of com.sun.enterprise.transaction.api.ResourceRecoveryManager.recoverIncompleteTx()

                _logger.log(Level.FINE, "Transaction log directory for " + instance + " is " + logdir);
                _logger.log(Level.FINE, "Starting transaction recovery of " + instance);
            }


            ResourceRecoveryManager recoveryManager = habitat.getComponent(ResourceRecoveryManager.class);
            recoveryManager.recoverIncompleteTx(true, logdir, instance, true);
            if (_logger.isLoggable(Level.FINE)) {
                _logger.log(Level.FINE, "Transaction recovery of " + instance + " is completed");
            }
        } catch (Throwable e) {
            _logger.log(Level.WARNING, "jts.recovery_error", e);

View Full Code Here

Examples of com.sun.enterprise.transaction.api.ResourceRecoveryManager.recoverIncompleteTx()

                _logger.log(Level.FINE, "Transaction log directory for " + instance + " is " + logdir);
                _logger.log(Level.FINE, "Starting transaction recovery of " + instance);
            }


            ResourceRecoveryManager recoveryManager = serviceLocator.getService(ResourceRecoveryManager.class);
            recoveryManager.recoverIncompleteTx(true, logdir, instance, true);
            if (_logger.isLoggable(Level.FINE)) {
                _logger.log(Level.FINE, "Transaction recovery of " + instance + " is completed");
            }
        } catch (Throwable e) {
            _logger.log(Level.WARNING, "jts.recovery_error", e);

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.