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

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
Rob Austin
2014-11-24 08:30:22 +00:00
parent a5fe252478 085e1cc99d
commit 12ceba9739
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java
+6 -4
View File
@@ -125,7 +125,7 @@ abstract class AbstractChronicleMapBuilder<K, V,
private int entrySize = 0;
private Alignment alignment = null;
private long entries = 1 << 20; // 1 million by default
private long lockTimeOut = 2000;
private long lockTimeOut = 20000;
private TimeUnit lockTimeOutUnit = TimeUnit.MILLISECONDS;
private int metaDataBytes = 0;
private ChronicleHashErrorListener errorListener = ChronicleHashErrorListeners.logging();
@@ -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) {