Configuration managerConfig = new Configuration()
.terracotta(new TerracottaClientConfiguration().url("localhost:9510").rejoin(true))
.cache(new CacheConfiguration().name("nonstop-sample")
.persistence(new PersistenceConfiguration().strategy(DISTRIBUTED))
.maxBytesLocalHeap(128, MemoryUnit.MEGABYTES)
.maxBytesLocalOffHeap(1, MemoryUnit.GIGABYTES)
.terracotta(new TerracottaConfiguration()
.nonstop(new NonstopConfiguration()
.immediateTimeout(false)
.timeoutMillis(10000).enabled(true)
)
));
CacheManager manager = CacheManager.create(managerConfig);
Ehcache bigMemory = manager.getEhcache("nonstop-sample");
try {
System.out.println("**** Put key 1 / value timDoe. ****");
final Person timDoe = new Person("Tim Doe", 35, Person.Gender.MALE,
"eck street", "San Mateo", "CA");
bigMemory.put(new Element("1", timDoe));
System.out.println("**** Get key 1 / value timDoe. ****");
System.out.println(bigMemory.get("1"));
waitForInput();
System.out
.println("**** Now you have to kill the server using the
stop-sample-server.bat on Windows or stop-sample-server.sh otherwise ****");
try {
while (true) {
bigMemory.get("1");
}
} catch (NonStopCacheException e) {
System.out
.println("**** Server is unreachable - NonStopException received when trying
to do a get on the server. NonStop is working ****");
}
System.out
.println("**** Now you have to restart the server using the start-sample-server.bat
on Windows or start-sample-server.sh otherwise ****");
boolean serverStart = false;
while (serverStart == false) {
try {
bigMemory.get("1");
//if server is unreachable, exception is thrown when doing the get
serverStart = true;
} catch (NonStopCacheException e) {
}
}
System.out
.println("**** Server is reachable - No More NonStopException received when
trying to do a get on the server. Rejoin is working ****");
} finally
{
if (manager != null) manager.shutdown();
}