diff --git a/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java b/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java index 35ea5b639..6c2946ee7 100755 --- a/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java +++ b/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java @@ -18,7 +18,10 @@ package net.openhft.chronicle.map; -import net.openhft.chronicle.hash.*; +import net.openhft.chronicle.hash.ChronicleHashBuilder; +import net.openhft.chronicle.hash.ChronicleHashErrorListener; +import net.openhft.chronicle.hash.ChronicleHashErrorListeners; +import net.openhft.chronicle.hash.ChronicleHashInstanceBuilder; import net.openhft.chronicle.hash.replication.*; import net.openhft.chronicle.hash.serialization.*; import net.openhft.chronicle.hash.serialization.internal.MetaBytesInterop; @@ -188,6 +191,11 @@ public final class ChronicleMapBuilder implements Cloneable, return new ChronicleMapBuilder<>(keyClass, valueClass); } + public static ChronicleMapStatelessClientBuilder of( + @NotNull Class keyClass, @NotNull Class valueClass, InetSocketAddress socketAddress) { + return ChronicleMapStatelessClientBuilder.of(socketAddress); + } + private static long roundUpMapHeaderSize(long headerSize) { long roundUp = (headerSize + 127L) & ~127L; if (roundUp - headerSize < 64) diff --git a/src/main/java/net/openhft/chronicle/map/ChronicleMapStatelessClientBuilder.java b/src/main/java/net/openhft/chronicle/map/ChronicleMapStatelessClientBuilder.java index 56671f35c..376ce0a5b 100644 --- a/src/main/java/net/openhft/chronicle/map/ChronicleMapStatelessClientBuilder.java +++ b/src/main/java/net/openhft/chronicle/map/ChronicleMapStatelessClientBuilder.java @@ -34,7 +34,7 @@ public final class ChronicleMapStatelessClientBuilder implements ChronicleMap>, MapBuilder> { - public static ChronicleMapStatelessClientBuilder of( + static ChronicleMapStatelessClientBuilder of( InetSocketAddress serverAddress) { return new ChronicleMapStatelessClientBuilder<>(serverAddress); } diff --git a/src/main/java/net/openhft/chronicle/set/ChronicleSetStatelessClientBuilder.java b/src/main/java/net/openhft/chronicle/set/ChronicleSetStatelessClientBuilder.java index b4224a502..9a8a029e5 100644 --- a/src/main/java/net/openhft/chronicle/set/ChronicleSetStatelessClientBuilder.java +++ b/src/main/java/net/openhft/chronicle/set/ChronicleSetStatelessClientBuilder.java @@ -17,6 +17,7 @@ package net.openhft.chronicle.set; import net.openhft.chronicle.hash.ChronicleHashStatelessClientBuilder; +import net.openhft.chronicle.map.ChronicleMapBuilder; import net.openhft.chronicle.map.ChronicleMapStatelessClientBuilder; import java.io.IOException; @@ -34,7 +35,8 @@ public final class ChronicleSetStatelessClientBuilder implements private final ChronicleMapStatelessClientBuilder mapClientBuilder; ChronicleSetStatelessClientBuilder(InetSocketAddress serverAddress) { - this.mapClientBuilder = ChronicleMapStatelessClientBuilder.of(serverAddress); + Class eClass = null; + this.mapClientBuilder = ChronicleMapBuilder.of(eClass, DummyValue.class, serverAddress); } @Override diff --git a/src/test/java/eg/BGChronicleTest.java b/src/test/java/eg/BGChronicleTest.java index f88c5e23f..17af2f6dd 100644 --- a/src/test/java/eg/BGChronicleTest.java +++ b/src/test/java/eg/BGChronicleTest.java @@ -3,7 +3,6 @@ package eg; import net.openhft.chronicle.hash.replication.TcpTransportAndNetworkConfig; import net.openhft.chronicle.map.ChronicleMap; import net.openhft.chronicle.map.ChronicleMapBuilder; -import net.openhft.chronicle.map.ChronicleMapStatelessClientBuilder; import java.io.Closeable; import java.io.File; @@ -102,8 +101,8 @@ public class BGChronicleTest { public Void call() throws IOException { InetSocketAddress serverAddress = REPLICAS > 1 && clientId % 2 == 0 ? remoteAddress2 : remoteAddress; - try (ChronicleMap map = ChronicleMapStatelessClientBuilder - .of(serverAddress) + try (ChronicleMap map = ChronicleMapBuilder + .of(byte[].class, byte[].class, serverAddress) .putReturnsNull(true) .removeReturnsNull(true) .create()) { @@ -138,8 +137,8 @@ public class BGChronicleTest { futureList2.add(es.submit(new Callable() { @Override public long[] call() throws IOException, InterruptedException { - try (ChronicleMap map = ChronicleMapStatelessClientBuilder - .of(remoteAddress) + try (ChronicleMap map = ChronicleMapBuilder + .of(byte[].class, byte[].class, remoteAddress) .putReturnsNull(true) .removeReturnsNull(true) .create()) { diff --git a/src/test/java/net/openhft/chronicle/map/CHMUseCasesTest.java b/src/test/java/net/openhft/chronicle/map/CHMUseCasesTest.java index 053e6ac5a..d945533ab 100644 --- a/src/test/java/net/openhft/chronicle/map/CHMUseCasesTest.java +++ b/src/test/java/net/openhft/chronicle/map/CHMUseCasesTest.java @@ -1126,12 +1126,12 @@ public class CHMUseCasesTest { })); try { - map.putMapped(1.0, new UnaryOperator() { - @Override - public Double update(Double s) { - return s + 1; - } - }); +map.putMapped(1.0, new UnaryOperator() { + @Override + public Double update(Double s) { + return s + 1; + } +}); } catch (Exception todoMoreSpecificException) { } diff --git a/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java b/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java index 860610016..76c36a822 100644 --- a/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java +++ b/src/test/java/net/openhft/chronicle/map/StatelessClientTest.java @@ -117,8 +117,8 @@ public class StatelessClientTest { serverMap.put(10, new StringBuilder("Hello World")); try (ChronicleMap statelessMap = - ChronicleMapStatelessClientBuilder - .of(new InetSocketAddress("localhost", port)) + ChronicleMapBuilder + .of(Integer.class, StringBuilder.class, new InetSocketAddress("localhost", port)) .putReturnsNull(true) .create()) { String actual = statelessMap.getMapped(10, ToString.INSTANCE); diff --git a/src/test/java/net/openhft/chronicle/map/example/ServersMapMain.java b/src/test/java/net/openhft/chronicle/map/example/ServersMapMain.java index 04f8e3e3c..52b23f223 100644 --- a/src/test/java/net/openhft/chronicle/map/example/ServersMapMain.java +++ b/src/test/java/net/openhft/chronicle/map/example/ServersMapMain.java @@ -21,7 +21,6 @@ package net.openhft.chronicle.map.example; import net.openhft.chronicle.hash.replication.TcpTransportAndNetworkConfig; import net.openhft.chronicle.map.ChronicleMap; import net.openhft.chronicle.map.ChronicleMapBuilder; -import net.openhft.chronicle.map.ChronicleMapStatelessClientBuilder; import java.io.File; import java.io.IOException; @@ -42,11 +41,11 @@ public class ServersMapMain { file.deleteOnExit(); final ChronicleMap serverMap = ChronicleMapBuilder.of(byte[].class, byte[].class) - .putReturnsNull(true) - .constantKeySizeBySample(new byte[8]) - .constantValueSizeBySample(new byte[32]) - .replication((byte) 2, TcpTransportAndNetworkConfig.of(port)) - .createPersistedTo(file); + .putReturnsNull(true) + .constantKeySizeBySample(new byte[8]) + .constantValueSizeBySample(new byte[32]) + .replication((byte) 2, TcpTransportAndNetworkConfig.of(port)) + .createPersistedTo(file); System.out.println("Server started"); System.in.read(); serverMap.close(); @@ -55,8 +54,8 @@ public class ServersMapMain { public static void startRemoteClient(String hostname) throws IOException { final ChronicleMap map; if (stateless) { - map = ChronicleMapStatelessClientBuilder - .of(new InetSocketAddress(hostname, port)) + map = ChronicleMapBuilder + .of(byte[].class, byte[].class, new InetSocketAddress(hostname, port)) .putReturnsNull(true) .create(); } else { @@ -65,8 +64,8 @@ public class ServersMapMain { TcpTransportAndNetworkConfig tcpConfig = TcpTransportAndNetworkConfig.of(port, new InetSocketAddress(hostname, port)); - map = ChronicleMapBuilder.of( - byte[].class, byte[].class) + map = ChronicleMapBuilder + .of(byte[].class, byte[].class) .putReturnsNull(true) .replication((byte) 1, tcpConfig) .createPersistedTo(file); diff --git a/src/test/java/net/openhft/chronicle/map/example/StringsMapMain.java b/src/test/java/net/openhft/chronicle/map/example/StringsMapMain.java index 98eabbd71..af2bffe69 100644 --- a/src/test/java/net/openhft/chronicle/map/example/StringsMapMain.java +++ b/src/test/java/net/openhft/chronicle/map/example/StringsMapMain.java @@ -21,7 +21,6 @@ package net.openhft.chronicle.map.example; import net.openhft.chronicle.hash.replication.TcpTransportAndNetworkConfig; import net.openhft.chronicle.map.ChronicleMap; import net.openhft.chronicle.map.ChronicleMapBuilder; -import net.openhft.chronicle.map.ChronicleMapStatelessClientBuilder; import java.io.File; import java.io.IOException; @@ -56,8 +55,8 @@ public class StringsMapMain { public static void startRemoteClient(String hostname) throws IOException { final ChronicleMap map; if (stateless) { - map = ChronicleMapStatelessClientBuilder - .of(new InetSocketAddress(hostname, port)) + map = ChronicleMapBuilder + .of(CharSequence.class, CharSequence.class, new InetSocketAddress(hostname, port)) .putReturnsNull(true) .create(); } else { diff --git a/src/test/java/net/openhft/chronicle/map/jsr166/map/StatelessChronicleMapTest.java b/src/test/java/net/openhft/chronicle/map/jsr166/map/StatelessChronicleMapTest.java index eb4c1f226..5f7c21f1a 100755 --- a/src/test/java/net/openhft/chronicle/map/jsr166/map/StatelessChronicleMapTest.java +++ b/src/test/java/net/openhft/chronicle/map/jsr166/map/StatelessChronicleMapTest.java @@ -267,8 +267,8 @@ public class StatelessChronicleMapTest extends JSR166TestCase { .replication((byte) 2, TcpTransportAndNetworkConfig.of(port)) .create(); - final ChronicleMap statelessMap = ChronicleMapStatelessClientBuilder - .of(new InetSocketAddress("localhost", port)) + final ChronicleMap statelessMap = ChronicleMapBuilder + .of(byte[].class, byte[].class, new InetSocketAddress("localhost", port)) .putReturnsNull(true) .create();