From a4cfcccca64c2eb730634db4607fced670349d78 Mon Sep 17 00:00:00 2001 From: Peter Lawrey Date: Tue, 18 Nov 2014 21:25:37 +0000 Subject: [PATCH] CHENT-8 Add a simple test to check put and remove work without the need for replication. --- .../openhft/chronicle/map/AbstractChronicleMapBuilder.java | 4 ++-- .../java/net/openhft/chronicle/map/ChronicleMapBuilder.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java b/src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java index 6565f9fc3..c487ef8ff 100755 --- a/src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java +++ b/src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java @@ -887,7 +887,7 @@ abstract class AbstractChronicleMapBuilder 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>) constructor.newInstance(statelessClients); + eventListener = (MapEventListener>) constructor.newInstance((Object) statelessClients); } catch (ClassNotFoundException e) { LoggerFactory.getLogger(getClass().getName()).warn("Chronicle Enterprise not found in the class path"); } catch (Exception e) { diff --git a/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java b/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java index d50a13cef..0ad9ed198 100755 --- a/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java +++ b/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java @@ -359,7 +359,7 @@ public final class ChronicleMapBuilder implements ChronicleMapBuilderI pushTo(InetSocketAddress... addresses) { + public ChronicleMapBuilder pushTo(InetSocketAddress... addresses) { delegate.pushTo(addresses); return this; }