From 8dab0ba7c039e9be3b1b0f3f69408cfbd8f9393d Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Fri, 22 May 2015 17:32:15 +0100 Subject: [PATCH] removed --- src/main/java/com/bacon/Main.java | 53 ------------------------------- 1 file changed, 53 deletions(-) delete mode 100644 src/main/java/com/bacon/Main.java diff --git a/src/main/java/com/bacon/Main.java b/src/main/java/com/bacon/Main.java deleted file mode 100644 index 6060ced7b..000000000 --- a/src/main/java/com/bacon/Main.java +++ /dev/null @@ -1,53 +0,0 @@ -package com.bacon; - -import net.openhft.chronicle.hash.replication.TcpTransportAndNetworkConfig; -import net.openhft.chronicle.map.ChronicleMap; -import net.openhft.chronicle.map.ChronicleMapBuilder; - -import java.io.File; -import java.io.IOException; -import java.net.InetSocketAddress; - -public class Main { - - public static void main(String[] args) throws IOException, InterruptedException { - - ChronicleMap server1 = null; - ChronicleMap server2 = null; - ChronicleMap replicaitonMap; - - { - final File tempFile = File.createTempFile("test", "chron"); - - server1 = ChronicleMapBuilder.of(String.class, String.class) - .replication((byte) 1).createPersistedTo(tempFile); - - TcpTransportAndNetworkConfig serverConfig = TcpTransportAndNetworkConfig.of(8088); - - replicaitonMap = ChronicleMapBuilder.of(String.class, String.class) - .replication((byte) 1, serverConfig).createPersistedTo(tempFile); - } - - { - InetSocketAddress s2address = new InetSocketAddress("localhost", 8088); - TcpTransportAndNetworkConfig server2Config = TcpTransportAndNetworkConfig.of(8090, s2address); - - server2 = ChronicleMapBuilder.of(String.class, String.class) - .replication((byte) 2, server2Config).create(); - } - - final String expected = "value"; - - server1.put("key", expected); - - String actual; - - do { - actual = server2.get("key"); - } while (actual == null); - - server1.close(); - server2.close(); - replicaitonMap.close(); - } -}