From edb2804007e400b2f4fd9b39a084f2e2e6ab5ea7 Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Tue, 21 Oct 2014 20:54:46 +0100 Subject: [PATCH] HCOLL-167 added test back in --- .../map/jrs166/map/StatelessClientTest.java | 53 +++++++++++++++++++ 1 file changed, 53 insertions(+) create mode 100644 src/test/java/net/openhft/chronicle/map/jrs166/map/StatelessClientTest.java diff --git a/src/test/java/net/openhft/chronicle/map/jrs166/map/StatelessClientTest.java b/src/test/java/net/openhft/chronicle/map/jrs166/map/StatelessClientTest.java new file mode 100644 index 000000000..b4d8adcd6 --- /dev/null +++ b/src/test/java/net/openhft/chronicle/map/jrs166/map/StatelessClientTest.java @@ -0,0 +1,53 @@ +package net.openhft.chronicle.map.jrs166.map; + +import net.openhft.chronicle.map.ChronicleMap; +import net.openhft.chronicle.map.ChronicleMapBuilder; +import net.openhft.chronicle.map.TcpReplicationConfig; +import org.junit.Test; +import org.testng.Assert; + +import java.io.IOException; +import java.net.InetSocketAddress; + +import static net.openhft.chronicle.common.StatelessBuilder.remoteAddress; + + +/** + * @author Rob Austin. + */ +public class StatelessClientTest { + + + @Test + public void test() throws IOException, InterruptedException { + + final ChronicleMap serverMap; + final ChronicleMap statelessMap; + +// server + { + serverMap = ChronicleMapBuilder.of(Integer.class, CharSequence.class) + .replicators((byte) 2, TcpReplicationConfig.of(8076)).create(); + + serverMap.put(10, "EXAMPLE-10"); + } + + +// stateless client + { + statelessMap = ChronicleMapBuilder.of(Integer + .class, CharSequence.class) + .stateless(remoteAddress(new InetSocketAddress("localhost", 8076))).create(); + + Assert.assertEquals("EXAMPLE-10", statelessMap.get(10)); + Assert.assertEquals(1, statelessMap.size()); + } + + serverMap.close(); + statelessMap.close(); + + } + + +} +