Examples of TransactionService


Examples of com.atomikos.icatch.TransactionService

    /**
     * @see com.atomikos.icatch.Participant#recover()
     */
    public boolean recover () throws SysException
    {
        TransactionService ts = Configuration.getTransactionService ();
        subordinateCoordinator = ts.getParticipant ( subordinateId );
        return subordinateCoordinator != null;
    }
View Full Code Here

Examples of com.atomikos.icatch.TransactionService

    /**
     * @see com.atomikos.icatch.Participant#recover()
     */
    public boolean recover () throws SysException
    {
        TransactionService ts = Configuration.getTransactionService ();
        subordinateCoordinator = ts.getParticipant ( subordinateId );
        return subordinateCoordinator != null;
    }
View Full Code Here

Examples of com.atomikos.icatch.TransactionService

    /**
     * @see com.atomikos.icatch.Participant#recover()
     */
    public boolean recover () throws SysException
    {
        TransactionService ts = Configuration.getTransactionService ();
        subordinateCoordinator = ts.getParticipant ( subordinateId );
        return subordinateCoordinator != null;
    }
View Full Code Here

Examples of com.atomikos.icatch.TransactionService

    /**
     * @see com.atomikos.icatch.Participant#recover()
     */
    public boolean recover () throws SysException
    {
        TransactionService ts = Configuration.getTransactionService ();
        subordinateCoordinator = ts.getParticipant ( subordinateId );
        return subordinateCoordinator != null;
    }
View Full Code Here

Examples of com.sun.corba.ee.spi.costransactions.TransactionService

      try {
          Class theJTSClass = Class.forName(clsName);

    if (theJTSClass != null) {
        try {
            TransactionService jts = (TransactionService)theJTSClass.newInstance();
      jts.identify_ORB(theORB, tsIdent, jtsProperties ) ;
      jtsInterceptor.setTSIdentification(tsIdent);
      // XXX should jts.get_current() be called everytime
      // resolve_initial_references is called ??
      org.omg.CosTransactions.Current transactionCurrent =
        jts.get_current();
     
      theORB.getLocalResolver().register(
                 ORBConstants.TRANSACTION_CURRENT_NAME,
                 new Constant(transactionCurrent));
     
View Full Code Here

Examples of com.sun.corba.ee.spi.costransactions.TransactionService

            try {
                Class theJTSClass = Class.forName(jtsClassName);

                if (theJTSClass != null) {
                        try {
                        TransactionService jts = (TransactionService)theJTSClass.newInstance();
                        jts.identify_ORB(theORB, tsIdent, jtsProperties ) ;
                        interceptor.setTSIdentification(tsIdent);

                        // V2-XXX should jts.get_current() be called everytime
                        // resolve_initial_references is called ??
                        org.omg.CosTransactions.Current transactionCurrent =
                                jts.get_current();

                        theORB.getLocalResolver().register(
                                ORBConstants.TRANSACTION_CURRENT_NAME,
                                ClosureFactory.makeConstant(transactionCurrent));
View Full Code Here

Examples of com.sun.enterprise.config.serverbeans.TransactionService

    public void recoverXAResources(boolean force) {
        if (force) {
            try {
                ConfigContext ctx =
                        ApplicationServer.getServerContext().getConfigContext();
                TransactionService txnService = null;
                txnService =
                        ServerBeansFactory.getTransactionServiceBean(ctx);
                PluggableFeatureFactory pff = ApplicationServer.getServerContext().
                        getPluggableFeatureFactory();
                TransactionRecovery transactionRecoveryService =
                        pff.getTransactionRecoveryService();
                //transactionRecoveryService.start(context) ;
                RecoveryManager.registerTransactionRecoveryService(transactionRecoveryService);
                if (!txnService.isAutomaticRecovery()) {
                    return;
                }
                if (_logger.isLoggable(Level.FINE)) {
                    _logger.log(Level.FINE, "ejbserver.recovery",
                            "Perform recovery of XAResources...");
View Full Code Here

Examples of com.sun.enterprise.config.serverbeans.TransactionService

        // If yes, put the mapping in the xaresourcewrappers properties.
        Properties xaresourcewrappers = new Properties();
        try {
            ConfigContext ctx =
                 ApplicationServer.getServerContext().getConfigContext();
            TransactionService txs =
                 ServerBeansFactory.getTransactionServiceBean(ctx);
            xaresourcewrappers.put(
                "oracle.jdbc.xa.client.OracleXADataSource",
                "com.sun.enterprise.transaction.OracleXAResource");
           
            ElementProperty[] eprops = txs.getElementProperty();
            for(int i=0;i<eprops.length;i++){
                String name = eprops[i].getName();
                String value = eprops[i].getValue();
                if(name.equals("oracle-xa-recovery-workaround")) {
                    if("false".equals(value)){
View Full Code Here

Examples of com.sun.enterprise.config.serverbeans.TransactionService

                   MonitoringRegistry registry = sCtx.getMonitoringRegistry();
                   JTAStatsImpl.createInstance(this);
                   JTAStatsImpl statImpl = JTAStatsImpl.getInstance();
                   registry.registerJTAStats(statImpl, statImpl);
                   _logger.log(Level.FINE,"JTAStats monitoring registration completed");
                   TransactionService txnService = ServerBeansFactory.getTransactionServiceBean(ctx);
                   ElementProperty[] eprops = txnService.getElementProperty();
                   for (int index = 0; index < eprops.length; index++) {
                       if ("pending-txn-cleanup-interval".equals(eprops[index].getName())) {
                           int interval = 60;
                           if (eprops[index].getValue() != null)
                               interval = Integer.parseInt(eprops[index].getValue());
View Full Code Here

Examples of com.sun.enterprise.config.serverbeans.TransactionService

        ServerContext sCtx = ApplicationServer.getServerContext();
        // running on the server side
        if (sCtx != null) {
            ConfigContext ctx = sCtx.getConfigContext();
            TransactionService txnService = null;
            try {
                txnService = ServerBeansFactory.getTransactionServiceBean(ctx);
                transactionTimeout = Integer.parseInt(txnService.getTimeoutInSeconds());
                ElementProperty[] eprops = txnService.getElementProperty();
                for (int index = 0; index < eprops.length; index++) {
                    if ("use-last-agent-optimization".equals(eprops[index].getName())) {
                        if ("false".equals(eprops[index].getValue())) {
                            useLAO = false;
                if (_logger.isLoggable(Level.FINE))
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.