Package org.infinispan.configuration.parsing

Examples of org.infinispan.configuration.parsing.ConfigurationBuilderHolder

156
157
158
159
160
161
162
163
164
165
166
167
         {
            public EmbeddedCacheManager run() throws Exception
            {
               Parser parser = new Parser(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
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
   @Deprecated
   public DefaultCacheManager(String globalConfigurationFile, String defaultConfigurationFile, String namedCacheFile,
                              boolean start) throws IOException {
      ParserRegistry parserRegistry = new ParserRegistry(Thread.currentThread().getContextClassLoader());

      ConfigurationBuilderHolder globalConfigurationBuilderHolder = parserRegistry.parseFile(globalConfigurationFile);
      ConfigurationBuilderHolder defaultConfigurationBuilderHolder = parserRegistry.parseFile(defaultConfigurationFile);

      globalConfiguration = globalConfigurationBuilderHolder.getGlobalConfigurationBuilder().build();
      defaultConfiguration = defaultConfigurationBuilderHolder.getDefaultConfigurationBuilder().build();

      if (namedCacheFile != null) {
         ConfigurationBuilderHolder namedConfigurationBuilderHolder = parserRegistry.parseFile(namedCacheFile);
         Entry<String, ConfigurationBuilder> entry = namedConfigurationBuilderHolder.getNamedConfigurationBuilders().entrySet().iterator().next();
         configurationOverrides.put(entry.getKey(), entry.getValue().build());
      }

      globalComponentRegistry = new GlobalComponentRegistry(this.globalConfiguration, this, caches.keySet());
      if (start)
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
          DEFAULT_INFINISPAN_CONFIGURATION_RESOURCENAME
      );
      final String transportOverrideResource = properties.getProperty( INFINISPAN_TRANSPORT_OVERRIDE_RESOURCENAME );
      try {
        InfinispanConfigurationParser ispnConfiguration = new InfinispanConfigurationParser( DefaultCacheManagerService.class.getClassLoader() );
        ConfigurationBuilderHolder configurationBuilderHolder = ispnConfiguration.parseFile( cfgName, transportOverrideResource );
        cacheManager = new DefaultCacheManager( configurationBuilderHolder, true );
        manageCacheManager = true;
      }
      catch (IOException e) {
        throw new SearchException(
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
      if ( is == null ) {
        throw new FileNotFoundException( filename );
      }
    }
    try {
      ConfigurationBuilderHolder builderHolder = configurationParser.parse( is );
      patchTransportConfiguration( builderHolder, transportOverrideResource );
      patchInfinispanClassLoader( builderHolder );
      return builderHolder;
    }
    finally {
View Full Code Here
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
    * @throws java.io.IOException if there is a problem reading the configuration stream
    */
   public DefaultCacheManager(InputStream configurationStream, boolean start) throws IOException {
      InputStream schemaInputStream = InfinispanConfiguration.findSchemaInputStream();
      try {
         ConfigurationBuilderHolder holder = new Parser(Thread.currentThread().getContextClassLoader()).parse(configurationStream);
        
         globalConfiguration = new LegacyGlobalConfigurationAdaptor().adapt(holder.getGlobalConfigurationBuilder().build());
         globalConfiguration.accept(configurationValidator);
         defaultConfiguration = new LegacyConfigurationAdaptor().adapt(holder.getDefaultConfigurationBuilder().build());
        
         for (ConfigurationBuilder b : holder.getConfigurationBuilders()) {
            org.infinispan.configuration.cache.Configuration c = b.build();
            Configuration legacy = new LegacyConfigurationAdaptor().adapt(c);
            configurationOverrides.put(c.name(), legacy);
         }
        
View Full Code Here
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
    */
   public DefaultCacheManager(String globalConfigurationFile, String defaultConfigurationFile, String namedCacheFile,
                              boolean start) throws IOException {
      Parser parser = new Parser(Thread.currentThread().getContextClassLoader());
     
      ConfigurationBuilderHolder globalConfigurationBuilderHolder = parser.parse(globalConfigurationFile);
      ConfigurationBuilderHolder defaultConfigurationBuilderHolder = parser.parse(defaultConfigurationFile);
     
      globalConfiguration = new LegacyGlobalConfigurationAdaptor().adapt(globalConfigurationBuilderHolder.getGlobalConfigurationBuilder().build());
      defaultConfiguration = new LegacyConfigurationAdaptor().adapt(defaultConfigurationBuilderHolder.getDefaultConfigurationBuilder().build());
     
      if (namedCacheFile != null) {
         ConfigurationBuilderHolder namedConfigurationBuilderHolder = parser.parse(namedCacheFile);
         org.infinispan.configuration.cache.Configuration c = namedConfigurationBuilderHolder.getConfigurationBuilders().iterator().next().build();
         defineConfiguration(c.name(), new LegacyConfigurationAdaptor().adapt(c));
      }

      globalComponentRegistry = new GlobalComponentRegistry(this.globalConfiguration, this, caches.keySet());
      cacheCreateLock = new ReentrantLock();
View Full Code Here
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
    *
    * @throws java.io.IOException if there is a problem reading the configuration stream
    */
   public DefaultCacheManager(InputStream configurationStream, boolean start) throws IOException {
      try {
         ConfigurationBuilderHolder holder = new Parser(Thread.currentThread().getContextClassLoader()).parse(configurationStream);
        
         globalConfiguration = LegacyGlobalConfigurationAdaptor.adapt(holder.getGlobalConfigurationBuilder().build());
         globalConfiguration.accept(configurationValidator);
         defaultConfiguration = LegacyConfigurationAdaptor.adapt(holder.getDefaultConfigurationBuilder().build());
        
         for (Entry<String, ConfigurationBuilder> entry : holder.getNamedConfigurationBuilders().entrySet()) {
            org.infinispan.configuration.cache.Configuration c = entry.getValue().build();
            Configuration legacy = LegacyConfigurationAdaptor.adapt(c);
            configurationOverrides.put(entry.getKey(), legacy);
         }
        
View Full Code Here
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
    */
   public DefaultCacheManager(String globalConfigurationFile, String defaultConfigurationFile, String namedCacheFile,
                              boolean start) throws IOException {
      Parser parser = new Parser(Thread.currentThread().getContextClassLoader());
     
      ConfigurationBuilderHolder globalConfigurationBuilderHolder = parser.parse(globalConfigurationFile);
      ConfigurationBuilderHolder defaultConfigurationBuilderHolder = parser.parse(defaultConfigurationFile);
     
      globalConfiguration = LegacyGlobalConfigurationAdaptor.adapt(globalConfigurationBuilderHolder.getGlobalConfigurationBuilder().build());
      defaultConfiguration = LegacyConfigurationAdaptor.adapt(defaultConfigurationBuilderHolder.getDefaultConfigurationBuilder().build());
     
      if (namedCacheFile != null) {
         ConfigurationBuilderHolder namedConfigurationBuilderHolder = parser.parse(namedCacheFile);
         Entry<String, ConfigurationBuilder> entry = namedConfigurationBuilderHolder.getNamedConfigurationBuilders().entrySet().iterator().next();
         defineConfiguration(entry.getKey(), LegacyConfigurationAdaptor.adapt(entry.getValue().build()));
      }

      globalComponentRegistry = new GlobalComponentRegistry(this.globalConfiguration, this, caches.keySet());
      cacheCreateLock = new ReentrantLock();
View Full Code Here
90
91
92
93
94
95
96
97
      return fromStream(is, false);
   }

   public static EmbeddedCacheManager fromStream(InputStream is, boolean keepJmxDomainName) throws IOException {
      ParserRegistry parserRegistry = new ParserRegistry(Thread.currentThread().getContextClassLoader());
      ConfigurationBuilderHolder holder = parserRegistry.parse(is);
      return createClusteredCacheManager(holder, keepJmxDomainName);
   }
View Full Code Here
465
466
467
468
469
470
471
472
473
474
475
   public static ConfigurationBuilderHolder buildAggregateHolder(String... xmls)
         throws XMLStreamException, FactoryConfigurationError {
      ClassLoader cl = Thread.currentThread().getContextClassLoader();
      ParserRegistry registry = new ParserRegistry(cl);

      ConfigurationBuilderHolder holder = new ConfigurationBuilderHolder(cl);
      for (String xml : xmls) {
         registry.parse(new ByteArrayInputStream(xml.getBytes()), holder);
      }

      return holder;
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.