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

HCOLL-216 reverted to prev version and sent peter and email as to why

Browse Source
This commit is contained in:
Rob Austin
2014-11-25 11:46:00 +00:00
parent ed323ac014
commit d23288ffec
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java
+3 -5
View File
@@ -888,15 +888,13 @@ abstract class AbstractChronicleMapBuilder<K, V,
}
try {
Class<?> pmel = Class.forName("com.higherfrequencytrading.chronicle.enterprise.map.PushingMapEventListener");
Constructor<?> constructor = pmel.getConstructor(ChronicleMapBuilderI[].class);
Constructor<?> constructor = pmel.getConstructor(ChronicleMap[].class);
// create a stateless client for each address
ChronicleMapBuilderI[] statelessClients = new ChronicleMapBuilderI[pushToAddresses.length];
ChronicleMap[] statelessClients = new ChronicleMap[pushToAddresses.length];
ChronicleMapBuilderI<K, V> cmb = clone();
cmb.pushTo((InetSocketAddress[]) null);
for (int i = 0; i < pushToAddresses.length; i++) {
ChronicleMapBuilderI<K, V> clientBuilder = cmb.clone();
clientBuilder.statelessClient(pushToAddresses[i]);
statelessClients[i] = clientBuilder;
statelessClients[i] = cmb.statelessClient(pushToAddresses[i]).create();
}
eventListener = (MapEventListener<K, V, ChronicleMap<K, V>>) constructor.newInstance((Object) statelessClients);
} catch (ClassNotFoundException e) {