diff --git a/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java b/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java index d4b346e45..14db1966c 100755 --- a/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java +++ b/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java @@ -163,8 +163,7 @@ public final class ChronicleMapBuilder implements DefaultValueProvider defaultValueProvider = DefaultSpi.defaultValueProvider(); private SingleChronicleHashReplication singleHashReplication = null; - private InetSocketAddress[] pushToAddresses; - + MapMethods methods = DefaultSpi.mapMethods(); MapEntryOperations entryOperations = mapEntryOperations(); MapRemoteOperations remoteOperations = mapRemoteOperations(); @@ -229,11 +228,6 @@ public final class ChronicleMapBuilder implements return obj != null ? obj + "" : "not configured"; } - public ChronicleMapBuilder pushTo(InetSocketAddress... addresses) { - this.pushToAddresses = addresses; - return this; - } - @Override public ChronicleMapBuilder clone() { try { @@ -1501,33 +1495,6 @@ public final class ChronicleMapBuilder implements throw new AssertionError(e); } } -// -// private void pushingToMapEventListener() { -// if (pushToAddresses == null || pushToAddresses.length == 0) { -// return; -// } -// try { -// Class pmel = Class.forName( -// "com.higherfrequencytrading.chronicle.enterprise.map.PushingMapEventListener"); -// Constructor constructor = pmel.getConstructor(ChronicleMap[].class); -// // create a stateless client for each address -// ChronicleMap[] statelessClients = new ChronicleMap[pushToAddresses.length]; -// ChronicleMapBuilder cmb = clone(); -// cmb.pushTo((InetSocketAddress[]) null); -// for (int i = 0; i < pushToAddresses.length; i++) { -// statelessClients[i] = ChronicleMapStatelessClientBuilder.of(pushToAddresses[i]) -// .create(); -// } -// eventListener = -// (MapEventListener) constructor.newInstance((Object) statelessClients); -// } catch (ClassNotFoundException e) { -// LoggerFactory.getLogger(getClass().getName()) -// .warn("Chronicle Enterprise not found in the class path"); -// } catch (Exception e) { -// LoggerFactory.getLogger(getClass().getName()) -// .error("PushingMapEventListener failed to load", e); -// } -// } private VanillaChronicleMap newMap( SingleChronicleHashReplication singleHashReplication, ReplicationChannel channel)