Package org.infinispan.manager

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

73
74
75
76
77
78
79
80
81
82
83
                entry = new LockManagerEntry(transport.getChannel());

                debug("Started lock manager for \"%s\" container", containerName);

                container.addListener(entry);

                lockManagers.put(containerName, entry);
            }

            String cacheName = cache.getName();
View Full Code Here
136
137
138
139
140
141
142
143
144
145
146
   public void testViewChange() throws Exception {
      EmbeddedCacheManager cmA = TestCacheManagerFactory.createClusteredCacheManager();
      cmA.getCache();
      CountDownLatch barrier = new CountDownLatch(1);
      GetCacheManagerCheckListener listener = new GetCacheManagerCheckListener(barrier);
      cmA.addListener(listener);
      CacheContainer cmB = TestCacheManagerFactory.createClusteredCacheManager();
      cmB.getCache();
      try {
         barrier.await();
         assert listener.cacheContainer != null;
View Full Code Here
229
230
231
232
233
234
235
236
237
238
239
  
   private void start(CacheContainerRegistryEntry entry)
   {
      EmbeddedCacheManager container = entry.getContainer();
      container.start();
      container.addListener(this.factory);
     
      String jndiName = entry.getJndiName();
     
      if (jndiName != null)
      {
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
      {
         Cache<Address, String> jvmRouteCache = getJvmRouteCache(this.sessionCache.getCacheManager(), this.manager);
        
         EmbeddedCacheManager container = (EmbeddedCacheManager) jvmRouteCache.getCacheManager();
        
         container.addListener(this.viewChangeListener);
        
         String jvmRoute = this.manager.getJvmRoute();
        
         if (jvmRoute != null)
         {
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
         EmbeddedCacheManager embeddedCacheManager = cacheManagerService.getEmbeddedCacheManager();
         TransactionManager transactionManager = componentRegistry.getComponent(TransactionManager.class);
         IndexLockController lockControl = new IndexManagerBasedLockController(indexManager, transactionManager);
         ClusteredSwitchingBackend backend = new ClusteredSwitchingBackend(componentRegistry, indexName, localBackendFactory, lockControl);
         backend.initialize();
         embeddedCacheManager.addListener(backend);
         return backend;
      }
   }

   @Override
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.