Package org.infinispan.config

Examples of org.infinispan.config.Configuration.fluent()

103
104
105
106
107
108
109
110
111
112
113
            .eviction().strategy(EvictionStrategy.NONE).maxEntries(10000)
            .transaction().transactionMode(org.infinispan.transaction.TransactionMode.TRANSACTIONAL).useSynchronization(true)
            ;
        for (Configuration.CacheMode mode: Configuration.CacheMode.values()) {
            Configuration configuration = defaultConfig.clone();
            FluentConfiguration.ClusteringConfig fluent = configuration.fluent().mode(mode);
            if (mode.isClustered()) {
                FluentConfiguration.StoreAsBinaryConfig binary = fluent.storeAsBinary();
                if (mode.isInvalidation()) {
                    // Don't serialize cache entry values
                    binary.storeValuesAsBinary(false);
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
        FluentGlobalConfiguration.GlobalJmxStatisticsConfig globalJmx = fluentTransport.globalJmxStatistics();
        globalJmx.cacheManagerName(this.configuration.getName());

        // setup default cache configuration
        Configuration defaultConfig = new Configuration();
        FluentConfiguration fluent = defaultConfig.fluent();

        MBeanServer server = this.configuration.getMBeanServer();
        if (server != null) {
            globalJmx.mBeanServerLookup(new MBeanServerProvider(server)).jmxDomain(SERVICE_NAME.getCanonicalName());
            fluent.jmxStatistics();
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
   private Configuration getDefaultRecoveryCacheConfig() {
      Configuration config = new Configuration();
      //the recovery cache should not participate in main cache's transactions, especially because removals
      // from this cache are executed in the context of a finalised transaction and cause issues.
      config.fluent().transaction().transactionMode(TransactionMode.NON_TRANSACTIONAL);
      config.fluent().clustering().mode(Configuration.CacheMode.LOCAL);
      config.fluent().expiration().lifespan(DEFAULT_EXPIRY);
      config.fluent().recovery().disable();
      return config;
   }
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
   private Configuration getDefaultRecoveryCacheConfig() {
      Configuration config = new Configuration();
      //the recovery cache should not participate in main cache's transactions, especially because removals
      // from this cache are executed in the context of a finalised transaction and cause issues.
      config.fluent().transaction().transactionMode(TransactionMode.NON_TRANSACTIONAL);
      config.fluent().clustering().mode(Configuration.CacheMode.LOCAL);
      config.fluent().expiration().lifespan(DEFAULT_EXPIRY);
      config.fluent().recovery().disable();
      return config;
   }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
      Configuration config = new Configuration();
      //the recovery cache should not participate in main cache's transactions, especially because removals
      // from this cache are executed in the context of a finalised transaction and cause issues.
      config.fluent().transaction().transactionMode(TransactionMode.NON_TRANSACTIONAL);
      config.fluent().clustering().mode(Configuration.CacheMode.LOCAL);
      config.fluent().expiration().lifespan(DEFAULT_EXPIRY);
      config.fluent().recovery().disable();
      return config;
   }

   private RecoveryManager buildRecoveryManager(String cacheName, String recoveryCacheName, EmbeddedCacheManager cm, boolean isDefault) {
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
      //the recovery cache should not participate in main cache's transactions, especially because removals
      // from this cache are executed in the context of a finalised transaction and cause issues.
      config.fluent().transaction().transactionMode(TransactionMode.NON_TRANSACTIONAL);
      config.fluent().clustering().mode(Configuration.CacheMode.LOCAL);
      config.fluent().expiration().lifespan(DEFAULT_EXPIRY);
      config.fluent().recovery().disable();
      return config;
   }

   private RecoveryManager buildRecoveryManager(String cacheName, String recoveryCacheName, EmbeddedCacheManager cm, boolean isDefault) {
      if (log.isTraceEnabled()) log.tracef("About to obtain a reference to the recovery cache: %s", recoveryCacheName);
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55

   @SuppressWarnings("unchecked")
   protected void createCacheManagers() throws Throwable {
      Configuration c = getConfig();
      c.fluent().transaction().autoCommit(false);
      createClusteredCaches(2, c);
   }

   protected Configuration getConfig() {
      return getDefaultClusteredConfig(sync() ? Configuration.CacheMode.REPL_SYNC : Configuration.CacheMode.REPL_ASYNC, true);
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
            .transport().strictPeerToPeer(false).distributedSyncTimeout(60000L)
            .shutdown().hookBehavior(ShutdownHookBehavior.DONT_REGISTER)
            ;
        Defaults defaults = new Defaults(global);
        Configuration defaultConfig = new Configuration();
        defaultConfig.fluent()
            .locking().lockAcquisitionTimeout(15000L).useLockStriping(false).concurrencyLevel(1000)
            .eviction().strategy(EvictionStrategy.NONE).maxEntries(10000)
            .transaction().useSynchronization(true)
            ;
        for (Configuration.CacheMode mode: Configuration.CacheMode.values()) {
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
            .eviction().strategy(EvictionStrategy.NONE).maxEntries(10000)
            .transaction().useSynchronization(true)
            ;
        for (Configuration.CacheMode mode: Configuration.CacheMode.values()) {
            Configuration configuration = defaultConfig.clone();
            FluentConfiguration.ClusteringConfig fluent = configuration.fluent().mode(mode);
            if (mode.isClustered()) {
                FluentConfiguration.StoreAsBinaryConfig binary = fluent.storeAsBinary();
                if (mode.isInvalidation()) {
                    // Don't serialize cache entry values
                    binary.storeValuesAsBinary(false);
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
   private Configuration getDefaultRecoveryCacheConfig() {
      Configuration config = new Configuration();
      //the recovery cache should not participate in main cache's transactions, especially because removals
      // from this cache are executed in the context of a finalised transaction and cause issues.
      config.fluent().transaction().transactionMode(TransactionMode.NON_TRANSACTIONAL);
      config.fluent().clustering().mode(Configuration.CacheMode.LOCAL);
      config.fluent().expiration().lifespan(DEFAULT_EXPIRY);
      config.fluent().recovery().disable();
      return config;
   }
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.