1 package com.atlassian.cache.hazelcast;
2
3 import com.atlassian.cache.AbstractLazyReferenceTest;
4 import com.atlassian.cache.CacheFactory;
5 import com.atlassian.cache.CacheSettingsBuilder;
6
7 import org.junit.After;
8 import org.junit.Before;
9 import org.junit.ClassRule;
10 import org.junit.Ignore;
11 import org.junit.Test;
12
13 public class HazelcastRemoteCachedReferenceTest extends AbstractLazyReferenceTest
14 {
15 @ClassRule
16 public static InitOnceHazelcastCluster cluster = InitOnceHazelcastCluster.getInstance();
17
18 private HazelcastCacheManager factory1;
19 private HazelcastCacheManager factory2;
20
21 @Before
22 public void setUp() throws Exception
23 {
24 cluster.reset();
25 factory1 = HazelcastTestSupport.createDistributedFactory(cluster.getNode(0));
26 factory2 = HazelcastTestSupport.createDistributedFactory(cluster.getNode(1));
27
28 factory = factory1;
29 }
30
31 @After
32 public void tearDown()
33 {
34 factory1.destroy();
35 factory2.destroy();
36 }
37
38 @Ignore("CACHE-106/CACHE-108: Needs to be fixed (currently hard fails)")
39 @Override
40 @Test
41 public void testResetConcurrentWithLoadLocal()
42 {
43 super.testResetConcurrentWithLoadLocal();
44 }
45
46 @Ignore("CACHE-106/CACHE-108: Needs to be fixed (currently flakey)")
47 @Test
48 public void testResetConcurrentWithLoadClustered()
49 {
50 final CacheFactory factory2 = HazelcastTestSupport.createDistributedFactory(cluster.getNode(1));
51 resetConcurrentWithLoad(factory, factory2);
52 }
53
54 @Override
55 protected CacheSettingsBuilder settingsBuilder()
56 {
57 return new CacheSettingsBuilder().remote();
58 }
59 }