Examples of org.jboss.tm.XAResourceRecoveryRegistry

org.jboss.tm.XAResourceRecoveryRegistry
The transaction management system may require assistance from resource managers in order to recover crashed XA transactions. By registering an XAResourceRecovery instance with the XAResourceRecoveryRegistry, resource manager connectors provide a way for the recovery system to callback to them and obtain the necessary information. This is useful for e.g. JDBC connection pools or JCA connectors that don't want to expose connection parameters to the transaction system. The connectors are responsible for instantiating a connection and using it to instantiate a set of XAResources. These are then exposed to the recovery system via the registered XAResourceRecovery instance. @author Jonathan Halliday (jonathan.halliday@redhat.com) @version $Revision$ @see XAResourceRecovery

        String cacheName = event.getCacheName();
        EmbeddedCacheManager container = event.getCacheManager();


        ROOT_LOGGER.cacheStarted(event.getCacheName(), event.getCacheManager().getGlobalConfiguration().getCacheManagerName());


        XAResourceRecoveryRegistry recoveryRegistry = this.configuration.getXAResourceRecoveryRegistry();
        if ((recoveryRegistry != null) && container.defineConfiguration(cacheName, new Configuration()).isTransactionRecoveryEnabled()) {
            recoveryRegistry.addXAResourceRecovery(new InfinispanXAResourceRecovery(cacheName, container));
        }
    }

View Full Code Here

       String cacheName = event.getCacheName();
       EmbeddedCacheManager container = event.getCacheManager();


       ROOT_LOGGER.cacheStopped(cacheName, container.getGlobalConfiguration().getCacheManagerName());


       XAResourceRecoveryRegistry recoveryRegistry = this.configuration.getXAResourceRecoveryRegistry();
       if (recoveryRegistry != null) {
           recoveryRegistry.removeXAResourceRecovery(new InfinispanXAResourceRecovery(cacheName, container));
       }
/*
       // Infinispan does not unregister cache mbean when cache stops (only when cache manager is stopped), so do it now to avoid classloader leaks
       MBeanServer server = this.configuration.getMBeanServer();
       if (server != null) {

View Full Code Here

0 1

TOP

Related Classes of org.jboss.tm.XAResourceRecoveryRegistry

org.jboss.as.clustering.infinispan.subsystem.CacheService

org.jboss.as.clustering.infinispan.subsystem.EmbeddedCacheManagerService

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.