diff --git a/pom.xml b/pom.xml
index faab8e639..2dcd66015 100755
--- a/pom.xml
+++ b/pom.xml
@@ -230,18 +230,14 @@
http://openhft.github.io/Chronicle-Algorithms/apidocs/
- net.openhft.chronicle.hash.serialization.internal:net.openhft.xstream:net.openhft.xstream.*:net.openhft.chronicle.hash.impl:net.openhft.chronicle.map.impl:net.openhft.chronicle.hash.hashing
+ net.openhft.chronicle.hash.serialization.impl:net.openhft.xstream:net.openhft.chronicle.hash.impl:net.openhft.chronicle.map.impl
net/openhft/chronicle/hash/ChronicleHashBuilderPrivateAPI.javanet/openhft/chronicle/hash/VanillaGlobalMutableState.java
- net/openhft/chronicle/hash/Segment.java
- net/openhft/chronicle/map/ConstantValueProvider.javanet/openhft/chronicle/map/VanillaChronicleMap.javanet/openhft/chronicle/map/Replica.javanet/openhft/chronicle/map/ReplicatedChronicleMap.java
- net/openhft/chronicle/map/ServiceDescriptor.java
- net/openhft/chronicle/map/TcpReplicator.javafalse-Xdoclint:none
diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
index d4559e452..4adce5c54 100644
--- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
@@ -51,22 +51,13 @@ import static net.openhft.chronicle.algo.MemoryUnit.*;
import static net.openhft.chronicle.algo.bytes.Access.checkedBytesStoreAccess;
import static net.openhft.chronicle.hash.impl.util.BuildVersion.version;
-interface Work {
-
- /**
- * @param in the buffer that we will fill up
- * @return true when all the work is complete
- */
- boolean doWork(@NotNull Bytes in);
-}
-
/**
* Used with a {@link net.openhft.chronicle.map.ReplicatedChronicleMap} to send data between the
* maps using a socket connection {@link net.openhft.chronicle.map.TcpReplicator}
*
* @author Rob Austin.
*/
-public final class TcpReplicator extends AbstractChannelReplicator implements Closeable {
+final class TcpReplicator extends AbstractChannelReplicator implements Closeable {
public static final long TIMESTAMP_FACTOR = 10000;
private static final int STATELESS_CLIENT = -127;
@@ -1437,5 +1428,14 @@ public final class TcpReplicator extends AbstractChannelReplicator impleme
return (entryOut.readRemaining() >= 8) ? entryOut.readLong() : Long.MIN_VALUE;
}
}
+
+ interface Work {
+
+ /**
+ * @param in the buffer that we will fill up
+ * @return true when all the work is complete
+ */
+ boolean doWork(@NotNull Bytes in);
+ }
}
diff --git a/src/main/java/net/openhft/chronicle/map/UdpReplicator.java b/src/main/java/net/openhft/chronicle/map/UdpReplicator.java
index c22067ef0..11c5d6123 100644
--- a/src/main/java/net/openhft/chronicle/map/UdpReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/UdpReplicator.java
@@ -33,7 +33,8 @@ import java.nio.channels.DatagramChannel;
* receive the data before it becomes available on TCP/IP. In order to not miss data, UdpReplicator
* should be used in conjunction with the TCP Replicator.
*/
-final class UdpReplicator extends UdpChannelReplicator implements Replica.ModificationNotifier, Closeable {
+final class UdpReplicator extends UdpChannelReplicator
+ implements Replica.ModificationNotifier, Closeable {
private static final Logger LOG =
LoggerFactory.getLogger(UdpReplicator.class.getName());