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-213 Thread local stateless client

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