* If the JHipster Registry is enabled, then the host list will be populated * from Eureka. * *

* If the JHipster Registry is not enabled, host discovery will be based on * the default transport settings defined in the 'config-file' packaged within * the Jar. The 'config-file' can be overridden using the application property * jhipster.cache.inifnispan.config-file * *

* If the JHipster Registry is not defined, you have the choice of 'config-file' * based on the underlying platform for hosts discovery. Infinispan * supports discovery natively for most of the platforms like Kubernets/OpenShift, * AWS, Azure and Google. * */ @Bean public InfinispanGlobalConfigurer globalConfiguration(JHipsterProperties jHipsterProperties) { log.info("Defining Infinispan Global Configuration"); <%_ if (serviceDiscoveryType === 'eureka') { _%> if(this.registration == null) { // if registry is not defined, use native discovery log.warn("No discovery service is set up, Infinispan will use default discovery for cluster formation"); return () -> GlobalConfigurationBuilder .defaultClusteredBuilder().transport().defaultTransport() .addProperty("configurationFile", jHipsterProperties.getCache().getInfinispan().getConfigFile()) .clusterName("infinispan-<%=baseName%>-cluster").globalJmxStatistics() .enabled(jHipsterProperties.getCache().getInfinispan().isStatsEnabled()) .allowDuplicateDomains(true).build(); } return () -> GlobalConfigurationBuilder .defaultClusteredBuilder().transport().transport(new JGroupsTransport(getTransportChannel())) .clusterName("infinispan-<%=baseName%>-cluster").globalJmxStatistics() .enabled(jHipsterProperties.getCache().getInfinispan().isStatsEnabled()) .allowDuplicateDomains(true).build(); <%_ }else { _%> return () -> GlobalConfigurationBuilder .defaultClusteredBuilder().transport().defaultTransport() .addProperty("configurationFile", jHipsterProperties.getCache().getInfinispan().getConfigFile()) .clusterName("infinispan-<%=baseName%>-cluster").globalJmxStatistics() .enabled(jHipsterProperties.getCache().getInfinispan().isStatsEnabled()) .allowDuplicateDomains(true).build(); <%_ } _%> } /** * Initialize cache configuration for Hibernate L2 cache and Spring Cache. *

* There are three different modes: local, distributed and replicated, and L2 cache options are pre-configured. * *

* It supports both jCache and Spring cache abstractions. *

* Usage: *

*
1. * jCache: *

   @CacheResult(cacheName="dist-app-data") 

   * - for creating a distributed cache. In a similar way other cache names and options can be used *
*
2. * Spring Cache: *

   @Cacheable(value = "repl-app-data") 

   * - for creating a replicated cache. In a similar way other cache names and options can be used *
*
3. * Cache manager can also be injected through DI/CDI and data can be manipulated using Infinispan APIs, *

        *          @Autowired (or) @Inject
        *          private EmbeddedCacheManager cacheManager;
        *
        *          void cacheSample(){
        *              cacheManager.getCache("dist-app-data").put("hi", "there");
        *          }
        *          

   *
*

* Instance of {@link JCacheManager} with cache being managed by the underlying Infinispan layer. This helps to record stats * info if enabled and the same is accessible through MBX:javax.cache,type=CacheStatistics. * *

* jCache stats are at instance level. If you need stats at clustering level, then it needs to be retrieved from MBX:org.infinispan * */ @Bean public JCacheManager getJCacheManager(EmbeddedCacheManager cacheManager, JHipsterProperties jHipsterProperties){ return new InfinispanJCacheManager(Caching.getCachingProvider().getDefaultURI(), cacheManager, Caching.getCachingProvider(), jHipsterProperties); } class InfinispanJCacheManager extends JCacheManager { public InfinispanJCacheManager(URI uri, EmbeddedCacheManager cacheManager, CachingProvider provider, JHipsterProperties jHipsterProperties) { super(uri, cacheManager, provider); // register individual caches to make the stats info available. <%_ if (authenticationType === 'oauth2' && applicationType === 'microservice') { _%> registerPredefinedCache("oAuth2Authentication", new JCache( cacheManager.getCache("oAuth2Authentication").getAdvancedCache(), this, ConfigurationAdapter.create())); <%_ } _%> <%_ if (!skipUserManagement || (authenticationType === 'oauth2' && applicationType !== 'microservice')) { _%> registerPredefinedCache(<%=packageName%>.repository.UserRepository.USERS_BY_LOGIN_CACHE, new JCache( cacheManager.getCache(<%=packageName%>.repository.UserRepository.USERS_BY_LOGIN_CACHE).getAdvancedCache(), this, ConfigurationAdapter.create())); registerPredefinedCache(<%=packageName%>.repository.UserRepository.USERS_BY_EMAIL_CACHE, new JCache( cacheManager.getCache(<%=packageName%>.repository.UserRepository.USERS_BY_EMAIL_CACHE).getAdvancedCache(), this, ConfigurationAdapter.create())); <%_ if (enableHibernateCache) { _%> registerPredefinedCache(<%=packageName%>.domain.User.class.getName(), new JCache( cacheManager.getCache(<%=packageName%>.domain.User.class.getName()).getAdvancedCache(), this, ConfigurationAdapter.create())); registerPredefinedCache(<%=packageName%>.domain.Authority.class.getName(), new JCache( cacheManager.getCache(<%=packageName%>.domain.Authority.class.getName()).getAdvancedCache(), this, ConfigurationAdapter.create())); registerPredefinedCache(<%=packageName%>.domain.User.class.getName() + ".authorities", new JCache( cacheManager.getCache(<%=packageName%>.domain.User.class.getName() + ".authorities").getAdvancedCache(), this, ConfigurationAdapter.create())); <%_ if (authenticationType === 'session') { _%> registerPredefinedCache(<%=packageName%>.domain.PersistentToken.class.getName(), new JCache( cacheManager.getCache(<%=packageName%>.domain.PersistentToken.class.getName()).getAdvancedCache(), this, ConfigurationAdapter.create())); registerPredefinedCache(<%=packageName%>.domain.User.class.getName() + ".persistentTokens", new JCache( cacheManager.getCache(<%=packageName%>.domain.User.class.getName() + ".persistentTokens").getAdvancedCache(), this, ConfigurationAdapter.create())); <%_ } _%> <%_ if (enableSocialSignIn) { _%> registerPredefinedCache(<%=packageName%>.domain.SocialUserConnection.class.getName(), new JCache( cacheManager.getCache(<%=packageName%>.domain.SocialUserConnection.class.getName()).getAdvancedCache(), this, ConfigurationAdapter.create())); <%_ } _%> <%_ } _%> <%_ } _%> // jhipster-needle-infinispan-add-entry if (jHipsterProperties.getCache().getInfinispan().isStatsEnabled()) { for (String cacheName : cacheManager.getCacheNames()) { enableStatistics(cacheName, true); } } } } <%_ if(serviceDiscoveryType === 'eureka') { _%> /** * TCP channel with the host details populated from the JHipster Registry. *

* MPING multicast is replaced with TCPPING with the host details discovered * from registry and sends only unicast messages to the host list. */ private Channel getTransportChannel() { JChannel channel = new JChannel(false); List initialHosts = new ArrayList<>(); try { for (ServiceInstance instance : discoveryClient.getInstances(registration.getServiceId())) { String clusterMember = instance.getHost() + ":7800"; log.debug("Adding Infinispan cluster member " + clusterMember); initialHosts.add(new IpAddress(clusterMember)); } TCP tcp = new TCP(); tcp.setBindAddress(InetAddress.getLocalHost()); tcp.setBindPort(7800); tcp.setThreadPoolMinThreads(2); tcp.setThreadPoolMaxThreads(30); tcp.setThreadPoolQueueEnabled(false); tcp.setThreadPoolKeepAliveTime(60000); tcp.setOOBThreadPoolMinThreads(2); tcp.setOOBThreadPoolMaxThreads(200); tcp.setOOBThreadPoolKeepAliveTime(60000); tcp.setOOBThreadPoolQueueEnabled(false); TCPPING tcpping = new TCPPING(); initialHosts.add(new IpAddress(InetAddress.getLocalHost(), 7800)); tcpping.setInitialHosts(initialHosts); tcpping.setErgonomics(false); tcpping.setPortRange(10); tcpping.sendCacheInformation(); NAKACK2 nakack = new NAKACK2(); nakack.setUseMcastXmit(false); nakack.setDiscardDeliveredMsgs(false); MERGE3 merge = new MERGE3(); merge.setMinInterval(10000); merge.setMaxInterval(30000); FD_ALL fd = new FD_ALL(); fd.setTimeout(60000); fd.setInterval(15000); fd.setTimeoutCheckInterval(5000); ProtocolStack stack = new ProtocolStack(); // Order shouldn't be changed stack .addProtocol(tcp) .addProtocol(tcpping) .addProtocol(merge) .addProtocol(new FD_SOCK()) .addProtocol(fd) .addProtocol(new VERIFY_SUSPECT()) .addProtocol(nakack) .addProtocol(new UNICAST3()) .addProtocol(new STABLE()) .addProtocol(new GMS()) .addProtocol(new MFC()) .addProtocol(new FRAG2()); channel.setProtocolStack(stack); stack.init(); } catch (Exception e) { throw new BeanInitializationException("Cache (Infinispan protocol stack) configuration failed", e); } return channel; } <%_ } _%> <%_ } _%> }