Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

Remove unused ChronicleEnterprise artifacts from ChronicleMapBuilder

Browse Source
This commit is contained in:
leventov
2015-08-05 02:49:07 +03:00
parent 8fe9960808
commit 8afd90c528
1 changed files with 1 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java
+1 -34
View File
@@ -163,8 +163,7 @@ public final class ChronicleMapBuilder<K, V> implements
DefaultValueProvider<K, V> defaultValueProvider = DefaultSpi.defaultValueProvider();
private SingleChronicleHashReplication singleHashReplication = null;
private InetSocketAddress[] pushToAddresses;
MapMethods<K, V, ?> methods = DefaultSpi.mapMethods();
MapEntryOperations<K, V, ?> entryOperations = mapEntryOperations();
MapRemoteOperations<K, V, ?> remoteOperations = mapRemoteOperations();
@@ -229,11 +228,6 @@ public final class ChronicleMapBuilder<K, V> implements
return obj != null ? obj + "" : "not configured";
}
public ChronicleMapBuilder<K, V> pushTo(InetSocketAddress... addresses) {
this.pushToAddresses = addresses;
return this;
}
@Override
public ChronicleMapBuilder<K, V> clone() {
try {
@@ -1501,33 +1495,6 @@ public final class ChronicleMapBuilder<K, V> 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<K, V> cmb = clone();
// cmb.pushTo((InetSocketAddress[]) null);
// for (int i = 0; i < pushToAddresses.length; i++) {
// statelessClients[i] = ChronicleMapStatelessClientBuilder.of(pushToAddresses[i])
// .create();
// }
// eventListener =
// (MapEventListener<K, V>) 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<K, ?, ?, V, ?, ?, ?> newMap(
SingleChronicleHashReplication singleHashReplication, ReplicationChannel channel)