From d23288ffecb5274317d1cb6faae8a9ab11747d6a Mon Sep 17 00:00:00 2001 From: Rob Austin Date: Tue, 25 Nov 2014 11:46:00 +0000 Subject: [PATCH] HCOLL-216 reverted to prev version and sent peter and email as to why --- .../chronicle/map/AbstractChronicleMapBuilder.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java b/src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java index fcc07f197..7307a8bb8 100755 --- a/src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java +++ b/src/main/java/net/openhft/chronicle/map/AbstractChronicleMapBuilder.java @@ -888,15 +888,13 @@ abstract class AbstractChronicleMapBuilder 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 cmb = clone(); cmb.pushTo((InetSocketAddress[]) null); for (int i = 0; i < pushToAddresses.length; i++) { - ChronicleMapBuilderI clientBuilder = cmb.clone(); - clientBuilder.statelessClient(pushToAddresses[i]); - statelessClients[i] = clientBuilder; + statelessClients[i] = cmb.statelessClient(pushToAddresses[i]).create(); } eventListener = (MapEventListener>) constructor.newInstance((Object) statelessClients); } catch (ClassNotFoundException e) {