Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * JBoss, Home of Professional Open Source
   * Copyright 2012 Red Hat Inc. and/or its affiliates and other contributors
   * as indicated by the @author tags. All rights reserved.
   * See the copyright.txt in the distribution for a
   * full listing of individual contributors.
   *
   * This copyrighted material is made available to anyone wishing to use,
   * modify, copy, or redistribute it subject to the terms and conditions
  * of the GNU Lesser General Public License, v. 2.1.
  * This program is distributed in the hope that it will be useful, but WITHOUT A
  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
  * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
  * You should have received a copy of the GNU Lesser General Public License,
  * v.2.1 along with this distribution; if not, write to the Free Software
  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
  * MA  02110-1301, USA.
  */
 package org.infinispan.upgrade.hotrod;
 
 import static org.testng.AssertJUnit.*;
 
 import java.util.List;
 
 
 @Test(testName = "loaders.remote.RemoteCacheStoreMixedAccessTest", groups = "functional")
 
    private HotRodServer sourceServer;
    private HotRodServer targetServer;
 
    @BeforeClass
    public void setup() throws Exception {
       ConfigurationBuilder serverBuilder = TestCacheManagerFactory.getDefaultCacheConfiguration(true);
        = TestCacheManagerFactory.createCacheManager(serverBuilder);
        = TestHelper.startHotRodServer();
 
       ConfigurationBuilder targetConfigurationBuilder = TestCacheManagerFactory.getDefaultCacheConfiguration(false);
       targetConfigurationBuilder.loaders().addStore(RemoteCacheStoreConfigurationBuilder.class).hotRodWrapping(true).addServer().host("localhost").port(.getPort());
 
        = TestCacheManagerFactory.createCacheManager(targetConfigurationBuilder);
        = TestHelper.startHotRodServer();
 
        = new RemoteCacheManager("localhost".getPort());
 
        = new RemoteCacheManager("localhost".getPort());
    }
 
    public void testSynchronization() throws Exception {
       // Fill the old cluster with data
       for (char ch = 'A'ch <= 'Z'ch++) {
          String s = Character.toString(ch);
          .put(ss);
       }
       // Verify access to some of the data from the new cluster
       assertEquals("A".get("A"));
 
       sourceUpgradeManager.recordKnownGlobalKeyset();
       targetUpgradeManager.synchronizeData("hotrod");
       // The server contains one extra key: MIGRATION_MANAGER_HOT_ROD_KNOWN_KEYS
 
      targetUpgradeManager.disconnectSource("hotrod");
      assertFalse(loaderManager.isEnabled());
   }
   @BeforeMethod(alwaysRun = true)
   public void cleanup() {
   }
   @AfterClass(alwaysRun = true)
   public void tearDown() {
      HotRodClientTestingUtil.killServers();
   }
New to GrepCode? Check out our FAQ X