Package org.infinispan.manager

Examples of org.infinispan.manager.EmbeddedCacheManager.addListener()

164
165
166
167
168
169
170
171
172
173
174
            defaultConfig.fluent().transaction().transactionSynchronizationRegistryLookup(
                new TransactionSynchronizationRegistryProvider(transactionSynchronizationRegistry));
        }

        EmbeddedCacheManager manager = new DefaultCacheManager(global, defaultConfig, false);
        manager.addListener(this);
        // Add named configurations
        for (Map.Entry<String, Configuration> entry: this.configuration.getConfigurations().entrySet()) {
            Configuration overrides = entry.getValue();
            Configuration configuration = defaults.getDefaultConfiguration(overrides.getCacheMode()).clone();
            configuration.applyOverrides(overrides);
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
        this.sessionCache.addListener(this);

        if (this.jvmRouteHandler != null) {
            EmbeddedCacheManager container = this.sessionCache.getCacheManager();

            container.addListener(this.jvmRouteHandler);

            String jvmRoute = this.manager.getJvmRoute();

            if (jvmRoute != null) {
                this.jvmRouteHandler.getCache().putIfAbsent(container.getAddress(), jvmRoute);
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
     
      if (this.sessionCache.getConfiguration().getCacheMode().isDistributed())
      {
         EmbeddedCacheManager container = (EmbeddedCacheManager) this.sessionCache.getCacheManager();
        
         container.addListener(this);
        
         String jvmRoute = this.manager.getJvmRoute();
        
         if (jvmRoute != null)
         {
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
               context.reset();
            }
           
            debug("Started lock manager for \"%s\" container", containerName);
           
            container.addListener(entry);
           
            lockManagers.put(containerName, entry);
         }
        
         String cacheName = cache.getName();
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
        this.sessionCache.addListener(this);

        if (this.jvmRouteHandler != null) {
            EmbeddedCacheManager container = this.sessionCache.getCacheManager();

            container.addListener(this.jvmRouteHandler);

            String jvmRoute = this.manager.getJvmRoute();

            if (jvmRoute != null) {
                this.jvmRouteHandler.getCache().putIfAbsent(container.getAddress(), jvmRoute);
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
     
      if (this.sessionCache.getConfiguration().getCacheMode().isDistributed())
      {
         EmbeddedCacheManager container = (EmbeddedCacheManager) this.sessionCache.getCacheManager();
        
         container.addListener(this);
        
         String jvmRoute = this.manager.getJvmRoute();
        
         if (jvmRoute != null)
         {
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
  
   private void start(CacheContainerRegistryEntry entry)
   {
      EmbeddedCacheManager container = entry.getContainer();
      container.start();
      container.addListener(entry);
     
      String jndiName = entry.getJndiName();
     
      if (jndiName != null)
      {
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
     
      if (this.viewChangeListener != null)
      {
         EmbeddedCacheManager container = (EmbeddedCacheManager) this.sessionCache.getCacheManager();
        
         container.addListener(this.viewChangeListener);
        
         String jvmRoute = this.manager.getJvmRoute();
        
         if (jvmRoute != null)
         {
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
         EmbeddedCacheManager embeddedCacheManager = cacheManagerService.getEmbeddedCacheManager();
         TransactionManager transactionManager = componentRegistry.getComponent(TransactionManager.class);
         IndexLockController lockControl = new IndexManagerBasedLockController(indexManager, transactionManager);
         ClusteredSwitchingBackend backend = new ClusteredSwitchingBackend(props, componentRegistry, indexName, localBackendFactory, lockControl);
         backend.initialize();
         embeddedCacheManager.addListener(backend);
         return backend;
      }
   }

   @Override
View Full Code Here
153
154
155
156
157
158
159
160
161
162
163
     
      if (this.cache.getConfiguration().getCacheMode().isDistributed())
      {
         EmbeddedCacheManager container = (EmbeddedCacheManager) this.cache.getCacheManager();
        
         container.addListener(this);
        
         this.getJvmRouteCache().putIfAbsent(container.getAddress(), this.manager.getJvmRoute());
      }
   }
  
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.