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

CHENT-8 Add a simple test to check put and remove work without the need for replication.

Browse Source
This commit is contained in:
Peter Lawrey
2014-11-18 21:25:37 +00:00
parent 091937113d
commit a4cfcccca6
2 changed files with 3 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
+2 -2
View File
@@ -887,7 +887,7 @@ abstract class AbstractChronicleMapBuilder<K, V,
return;
}
try {
Class<?> pmel = Class.forName("com.higherfrequencytrading.chronicle.engine.map.PushingMapEventListener");
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];
@@ -897,7 +897,7 @@ abstract class AbstractChronicleMapBuilder<K, V,
cmb.statelessClient(pushToAddresses[i]);
statelessClients[i] = cmb.create();
}
eventListener = (MapEventListener<K, V, ChronicleMap<K, V>>) constructor.newInstance(statelessClients);
eventListener = (MapEventListener<K, V, ChronicleMap<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) {
src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java
+1 -1
View File
@@ -359,7 +359,7 @@ public final class ChronicleMapBuilder<K, V> implements ChronicleMapBuilderI<K,
}
@Override
public ChronicleMapBuilderI<K, V> pushTo(InetSocketAddress... addresses) {
public ChronicleMapBuilder<K, V> pushTo(InetSocketAddress... addresses) {
delegate.pushTo(addresses);
return this;
}