163 GlobalConfigurationBuilder gcb =
new GlobalConfigurationBuilder();
165 boolean clustered =
config.getBoolean(
"clustered",
false);
166 boolean async =
config.getBoolean(
"async",
false);
167 boolean allowDuplicateJMXDomains =
config.getBoolean(
"allowDuplicateJMXDomains",
true);
172 String jgroupsUdpMcastAddr =
config.get(
"jgroupsUdpMcastAddr", System.getProperty(InfinispanConnectionProvider.JGROUPS_UDP_MCAST_ADDR));
174 gcb.globalJmxStatistics()
178 gcb.globalJmxStatistics()
179 .allowDuplicateDomains(allowDuplicateJMXDomains)
185 logger.debug(
"Started embedded Infinispan cache container");
187 ConfigurationBuilder modelCacheConfigBuilder =
new ConfigurationBuilder();
188 Configuration modelCacheConfiguration = modelCacheConfigBuilder.build();
190 cacheManager.defineConfiguration(InfinispanConnectionProvider.REALM_CACHE_NAME, modelCacheConfiguration);
191 cacheManager.defineConfiguration(InfinispanConnectionProvider.AUTHORIZATION_CACHE_NAME, modelCacheConfiguration);
192 cacheManager.defineConfiguration(InfinispanConnectionProvider.USER_CACHE_NAME, modelCacheConfiguration);
194 ConfigurationBuilder sessionConfigBuilder =
new ConfigurationBuilder();
196 String sessionsMode =
config.get(
"sessionsMode",
"distributed");
197 if (sessionsMode.equalsIgnoreCase(
"replicated")) {
198 sessionConfigBuilder.clustering().cacheMode(async ? CacheMode.REPL_ASYNC : CacheMode.REPL_SYNC);
199 }
else if (sessionsMode.equalsIgnoreCase(
"distributed")) {
200 sessionConfigBuilder.clustering().cacheMode(async ? CacheMode.DIST_ASYNC : CacheMode.DIST_SYNC);
202 throw new RuntimeException(
"Invalid value for sessionsMode");
205 int l1Lifespan =
config.getInt(
"l1Lifespan", 600000);
206 boolean l1Enabled = l1Lifespan > 0;
207 sessionConfigBuilder.clustering()
209 .numOwners(
config.getInt(
"sessionsOwners", 2))
210 .numSegments(
config.getInt(
"sessionsSegments", 60))
213 .lifespan(l1Lifespan)
218 Configuration sessionCacheConfigurationBase = sessionConfigBuilder.build();
220 boolean jdgEnabled =
config.getBoolean(
"remoteStoreEnabled",
false);
223 sessionConfigBuilder =
new ConfigurationBuilder();
224 sessionConfigBuilder.read(sessionCacheConfigurationBase);
227 Configuration sessionCacheConfiguration = sessionConfigBuilder.build();
228 cacheManager.defineConfiguration(InfinispanConnectionProvider.USER_SESSION_CACHE_NAME, sessionCacheConfiguration);
231 sessionConfigBuilder =
new ConfigurationBuilder();
232 sessionConfigBuilder.read(sessionCacheConfigurationBase);
233 configureRemoteCacheStore(sessionConfigBuilder, async, InfinispanConnectionProvider.OFFLINE_USER_SESSION_CACHE_NAME,
true);
235 sessionCacheConfiguration = sessionConfigBuilder.build();
236 cacheManager.defineConfiguration(InfinispanConnectionProvider.OFFLINE_USER_SESSION_CACHE_NAME, sessionCacheConfiguration);
239 sessionConfigBuilder =
new ConfigurationBuilder();
240 sessionConfigBuilder.read(sessionCacheConfigurationBase);
243 sessionCacheConfiguration = sessionConfigBuilder.build();
244 cacheManager.defineConfiguration(InfinispanConnectionProvider.CLIENT_SESSION_CACHE_NAME, sessionCacheConfiguration);
247 sessionConfigBuilder =
new ConfigurationBuilder();
248 sessionConfigBuilder.read(sessionCacheConfigurationBase);
249 configureRemoteCacheStore(sessionConfigBuilder, async, InfinispanConnectionProvider.OFFLINE_CLIENT_SESSION_CACHE_NAME,
true);
251 sessionCacheConfiguration = sessionConfigBuilder.build();
252 cacheManager.defineConfiguration(InfinispanConnectionProvider.OFFLINE_CLIENT_SESSION_CACHE_NAME, sessionCacheConfiguration);
255 sessionConfigBuilder =
new ConfigurationBuilder();
256 sessionConfigBuilder.read(sessionCacheConfigurationBase);
259 sessionCacheConfiguration = sessionConfigBuilder.build();
260 cacheManager.defineConfiguration(InfinispanConnectionProvider.LOGIN_FAILURE_CACHE_NAME, sessionCacheConfiguration);
262 cacheManager.defineConfiguration(InfinispanConnectionProvider.AUTHENTICATION_SESSIONS_CACHE_NAME, sessionCacheConfigurationBase);
265 cacheManager.getCache(InfinispanConnectionProvider.USER_SESSION_CACHE_NAME,
true);
266 cacheManager.getCache(InfinispanConnectionProvider.OFFLINE_USER_SESSION_CACHE_NAME,
true);
267 cacheManager.getCache(InfinispanConnectionProvider.CLIENT_SESSION_CACHE_NAME,
true);
268 cacheManager.getCache(InfinispanConnectionProvider.OFFLINE_CLIENT_SESSION_CACHE_NAME,
true);
269 cacheManager.getCache(InfinispanConnectionProvider.LOGIN_FAILURE_CACHE_NAME,
true);
270 cacheManager.getCache(InfinispanConnectionProvider.AUTHENTICATION_SESSIONS_CACHE_NAME,
true);
272 ConfigurationBuilder replicationConfigBuilder =
new ConfigurationBuilder();
274 replicationConfigBuilder.clustering().cacheMode(async ? CacheMode.REPL_ASYNC : CacheMode.REPL_SYNC);
281 Configuration replicationEvictionCacheConfiguration = replicationConfigBuilder.build();
282 cacheManager.defineConfiguration(InfinispanConnectionProvider.WORK_CACHE_NAME, replicationEvictionCacheConfiguration);
284 long realmRevisionsMaxEntries =
cacheManager.getCache(InfinispanConnectionProvider.REALM_CACHE_NAME).getCacheConfiguration().memory().size();
285 realmRevisionsMaxEntries = realmRevisionsMaxEntries > 0
286 ? 2 * realmRevisionsMaxEntries
287 : InfinispanConnectionProvider.REALM_REVISIONS_CACHE_DEFAULT_MAX;
290 cacheManager.getCache(InfinispanConnectionProvider.REALM_REVISIONS_CACHE_NAME,
true);
292 long userRevisionsMaxEntries =
cacheManager.getCache(InfinispanConnectionProvider.USER_CACHE_NAME).getCacheConfiguration().memory().size();
293 userRevisionsMaxEntries = userRevisionsMaxEntries > 0
294 ? 2 * userRevisionsMaxEntries
295 : InfinispanConnectionProvider.USER_REVISIONS_CACHE_DEFAULT_MAX;
298 cacheManager.getCache(InfinispanConnectionProvider.USER_REVISIONS_CACHE_NAME,
true);
301 cacheManager.getCache(InfinispanConnectionProvider.KEYS_CACHE_NAME,
true);
305 actionTokenCacheConfigBuilder.clustering().cacheMode(async ? CacheMode.REPL_ASYNC : CacheMode.REPL_SYNC);
310 cacheManager.defineConfiguration(InfinispanConnectionProvider.ACTION_TOKEN_CACHE, actionTokenCacheConfigBuilder.build());
311 cacheManager.getCache(InfinispanConnectionProvider.ACTION_TOKEN_CACHE,
true);
313 long authzRevisionsMaxEntries =
cacheManager.getCache(InfinispanConnectionProvider.AUTHORIZATION_CACHE_NAME).getCacheConfiguration().memory().size();
314 authzRevisionsMaxEntries = authzRevisionsMaxEntries > 0
315 ? 2 * authzRevisionsMaxEntries
316 : InfinispanConnectionProvider.AUTHORIZATION_REVISIONS_CACHE_DEFAULT_MAX;
319 cacheManager.getCache(InfinispanConnectionProvider.AUTHORIZATION_REVISIONS_CACHE_NAME,
true);
ConfigurationBuilder getActionTokenCacheConfig()
Definition: DefaultInfinispanConnectionProviderFactory.java:406
boolean containerManaged
Definition: DefaultInfinispanConnectionProviderFactory.java:62
Configuration getRevisionCacheConfig(long maxEntries)
Definition: DefaultInfinispanConnectionProviderFactory.java:323
Configuration getKeysCacheConfig()
Definition: DefaultInfinispanConnectionProviderFactory.java:394
Config.Scope config
Definition: DefaultInfinispanConnectionProviderFactory.java:56
TopologyInfo topologyInfo
Definition: DefaultInfinispanConnectionProviderFactory.java:64
String getMySiteName()
Definition: TopologyInfo.java:117
static final Logger logger
Definition: DefaultInfinispanConnectionProviderFactory.java:54
String getMyNodeName()
Definition: TopologyInfo.java:113
void configureRemoteCacheStore(ConfigurationBuilder builder, boolean async, String cacheName, boolean sessionCache)
Definition: DefaultInfinispanConnectionProviderFactory.java:341
void configureTransport(GlobalConfigurationBuilder gcb, String nodeName, String siteName, String jgroupsUdpMcastAddr)
Definition: DefaultInfinispanConnectionProviderFactory.java:422
EmbeddedCacheManager cacheManager
Definition: DefaultInfinispanConnectionProviderFactory.java:58
void configureRemoteActionTokenCacheStore(ConfigurationBuilder builder, boolean async)
Definition: DefaultInfinispanConnectionProviderFactory.java:369