From 64aaa6c54ec8fc71589c8826281dadce1abbf3b2 Mon Sep 17 00:00:00 2001
From: Rob Austin <rob.austin@boundedbuffer.co.uk>
Date: Fri, 4 Dec 2015 10:22:10 +0000
Subject: [PATCH] added missing         final InetSocketAddress
 serverInetSocketAddress =                 new
 InetSocketAddress(replicationConfig.serverPort());         final Details
 serverDetails = new Details(serverInetSocketAddress, localIdentifier);

        attached.connector = new ServerConnector(serverDetails);
---
 .../java/net/openhft/chronicle/map/TcpReplicator.java    | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
index 2f8803f37..8b248e7a1 100644
--- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
@@ -518,6 +518,12 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
         channel.socket().setSoLinger(false, 0);
 
         final Attached attached = new Attached();
+
+        final InetSocketAddress serverInetSocketAddress =
+                new InetSocketAddress(replicationConfig.serverPort());
+        final Details serverDetails = new Details(serverInetSocketAddress, localIdentifier);
+
+        attached.connector = new ServerConnector(serverDetails);
         attached.entryReader = new TcpSocketChannelEntryReader();
         attached.entryWriter = new TcpSocketChannelEntryWriter();
 
@@ -933,8 +939,7 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
         }
 
         @Nullable
-        SelectableChannel doConnect() throws
-                IOException, InterruptedException {
+        SelectableChannel doConnect() throws IOException, InterruptedException {
 
             final ServerSocketChannel serverChannel = openServerSocketChannel();