Package org.infinispan.configuration.parsing

Examples of org.infinispan.configuration.parsing.ConfigurationBuilderHolder

75
76
77
78
79
80
81
82
83
84
85
86
      }

      this.uri = uri;
      this.provider = provider;

      ConfigurationBuilderHolder cbh = getConfigurationBuilderHolder(classLoader);
      GlobalConfigurationBuilder globalBuilder = cbh.getGlobalConfigurationBuilder();
      // The cache manager name has to contain all uri, class loader and
      // provider information in order to guarantee JMX naming uniqueness.
      // This is tested by the TCK to make sure caching provider loaded
      // with different classloaders, even if the default classloader for
      // the cache manager is the same, are really different cache managers.
View Full Code Here
127
128
129
130
131
132
133
134
               ? fileLookup.lookupFileStrict(uri, classLoader)
               : fileLookup.lookupFileStrict(uri.toString(), classLoader);
         return new ParserRegistry(classLoader).parse(configurationStream);
      } catch (FileNotFoundException e) {
         // No such file, lets use default CBH
         return new ConfigurationBuilderHolder(classLoader);
      }
   }
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
          INFINISPAN_CONFIGURATION_RESOURCENAME,
          DEFAULT_INFINISPAN_CONFIGURATION_RESOURCENAME
      );
      try {
        InfinispanConfigurationParser ispnConfiguration = new InfinispanConfigurationParser( CacheManagerServiceProvider.class.getClassLoader() );
        ConfigurationBuilderHolder configurationBuilderHolder = ispnConfiguration.parseFile( cfgName );
        cacheManager = new DefaultCacheManager( configurationBuilderHolder, true );
        manageCacheManager = true;
      }
      catch (IOException e) {
        throw new SearchException(
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
    InputStream is = fileLookup.lookupFile( filename, searchConfigClassloader );
    if ( is == null ) {
      throw new FileNotFoundException( filename );
    }
    try {
      ConfigurationBuilderHolder builderHolder = configurationParser.parse( is );
      patchInfinispanClassLoader( builderHolder );
      return builderHolder;
    }
    finally {
      Util.close( is );
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
    private static final ModuleIdentifier QUERY_MODULE = ModuleIdentifier.fromString("org.infinispan.query");
    private static volatile Map<CacheMode, Configuration> defaults = null;

    public static synchronized Configuration getDefaultConfiguration(CacheMode cacheMode) {
        if (defaults == null) {
            ConfigurationBuilderHolder holder = load(DEFAULTS);
            Configuration defaultConfig = holder.getDefaultConfigurationBuilder().build();
            Map<CacheMode, Configuration> map = new EnumMap<>(CacheMode.class);
            map.put(defaultConfig.clustering().cacheMode(), defaultConfig);
            for (ConfigurationBuilder builder : holder.getNamedConfigurationBuilders().values()) {
                Configuration config = builder.build();
                map.put(config.clustering().cacheMode(), config);
            }
            for (CacheMode mode : CacheMode.values()) {
                if (!map.containsKey(mode)) {
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
    private static final String DEFAULTS = "infinispan-defaults.xml";
    private static volatile Map<CacheMode, Configuration> defaults = null;

    public static synchronized Configuration getDefaultConfiguration(CacheMode cacheMode) {
        if (defaults == null) {
            ConfigurationBuilderHolder holder = load(DEFAULTS);
            Configuration defaultConfig = holder.getDefaultConfigurationBuilder().build();
            Map<CacheMode, Configuration> map = new EnumMap<CacheMode, Configuration>(CacheMode.class);
            map.put(defaultConfig.clustering().cacheMode(), defaultConfig);
            for (ConfigurationBuilder builder : holder.getNamedConfigurationBuilders().values()) {
                Configuration config = builder.build();
                map.put(config.clustering().cacheMode(), config);
            }
            for (CacheMode mode : CacheMode.values()) {
                if (!map.containsKey(mode)) {
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
            ModelKeys.STRING_KEYED_JDBC_STORE, ModelKeys.BINARY_KEYED_JDBC_STORE, ModelKeys.MIXED_KEYED_JDBC_STORE,
            ModelKeys.REMOTE_STORE, ModelKeys.LEVELDB_STORE, ModelKeys.REST_STORE };

    public static synchronized Configuration getDefaultConfiguration(CacheMode cacheMode) {
        if (defaults == null) {
            ConfigurationBuilderHolder holder = load(DEFAULTS);
            Configuration defaultConfig = holder.getDefaultConfigurationBuilder().build();
            Map<CacheMode, Configuration> map = new EnumMap<CacheMode, Configuration>(CacheMode.class);
            map.put(defaultConfig.clustering().cacheMode(), defaultConfig);
            for (ConfigurationBuilder builder : holder.getNamedConfigurationBuilders().values()) {
                Configuration config = builder.build();
                map.put(config.clustering().cacheMode(), config);
            }
            for (CacheMode mode : CacheMode.values()) {
                if (!map.containsKey(mode)) {
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
94
      }

      this.uri = uri;
      this.provider = provider;

      ConfigurationBuilderHolder cbh = getConfigurationBuilderHolder(classLoader);
      GlobalConfigurationBuilder globalBuilder = cbh.getGlobalConfigurationBuilder();
      // The cache manager name has to contain all uri, class loader and
      // provider information in order to guarantee JMX naming uniqueness.
      // This is tested by the TCK to make sure caching provider loaded
      // with different classloaders, even if the default classloader for
      // the cache manager is the same, are really different cache managers.
View Full Code Here
135
136
137
138
139
140
141
142
               ? fileLookup.lookupFileStrict(uri, classLoader)
               : fileLookup.lookupFileStrict(uri.toString(), classLoader);
         return new ParserRegistry(classLoader).parse(configurationStream);
      } catch (FileNotFoundException e) {
         // No such file, lets use default CBH
         return new ConfigurationBuilderHolder(classLoader);
      }
   }
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
175
         {
            public EmbeddedCacheManager run() throws Exception
            {
               ParserRegistry parser = new ParserRegistry(Thread.currentThread().getContextClassLoader());
               // Loads the configuration from the input stream
               ConfigurationBuilderHolder holder = parser.parse(configStream);
               GlobalConfigurationBuilder configBuilder = holder.getGlobalConfigurationBuilder();
               Utils.loadJGroupsConfig(configurationManager, configBuilder.build(), configBuilder);
               return getUniqueInstance(regionIdEscaped, holder, transactionManager);
            }
         });
View Full Code Here
TOP

Related Classes of org.infinispan.configuration.parsing.ConfigurationBuilderHolder

  • org.exoplatform.services.cache.impl.infinispan.ExoCacheFactoryImpl
  • org.exoplatform.services.ispn.DistributedCacheManager
  • org.exoplatform.services.jcr.infinispan.ISPNCacheFactory
  • org.hibernate.cache.infinispan.InfinispanRegionFactory
  • org.hibernate.ogm.datastore.infinispan.utils.InfinispanNode
  • org.hibernate.search.infinispan.CacheManagerServiceProvider
  • org.hibernate.search.infinispan.DefaultCacheManagerService
  • org.hibernate.search.infinispan.impl.InfinispanConfigurationParser
  • org.infinispan.configuration.cache.ConfigurationBuilder
  • org.infinispan.configuration.global.GlobalConfigurationBuilder
    • Copyright © 2018 www.massapicom. 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.