mirror of
https://github.com/OpenHFT/Chronicle-Map.git
synced 2021-09-13 01:26:12 +00:00
HCOLL-163 corrected bad naming of Udp and TCP ReplicationConfig
This commit is contained in:
@@ -68,7 +68,7 @@ public class Builder {
|
||||
final byte identifier,
|
||||
final int serverPort,
|
||||
final InetSocketAddress... endpoints) throws IOException {
|
||||
TcpReplicationReplicatorConfig tcpConfig = TcpReplicationReplicatorConfig.of(serverPort, endpoints)
|
||||
TcpReplicationConfig tcpConfig = TcpReplicationConfig.of(serverPort, endpoints)
|
||||
.heartBeatInterval(1L, SECONDS);
|
||||
return ChronicleMapBuilder.of(kClass, vClass)
|
||||
.entries(20000L)
|
||||
|
||||
@@ -51,7 +51,7 @@ public class ChannelReplicationTest {
|
||||
|
||||
public void setup() throws IOException {
|
||||
{
|
||||
TcpReplicationReplicatorConfig tcpConfig = TcpReplicationReplicatorConfig
|
||||
TcpReplicationConfig tcpConfig = TcpReplicationConfig
|
||||
.of(8086, new InetSocketAddress("localhost", 8087))
|
||||
.heartBeatInterval(1, SECONDS);
|
||||
|
||||
@@ -66,8 +66,8 @@ public class ChannelReplicationTest {
|
||||
}
|
||||
|
||||
{
|
||||
TcpReplicationReplicatorConfig tcpConfig =
|
||||
TcpReplicationReplicatorConfig.of(8087).heartBeatInterval(1, SECONDS);
|
||||
TcpReplicationConfig tcpConfig =
|
||||
TcpReplicationConfig.of(8087).heartBeatInterval(1, SECONDS);
|
||||
|
||||
channelProviderB = new ChannelProviderBuilder().replicators((byte) 2, tcpConfig)
|
||||
.create();
|
||||
|
||||
@@ -59,7 +59,7 @@ public class PostChannelCreationTest {
|
||||
public void setup() throws IOException {
|
||||
|
||||
{
|
||||
final TcpReplicationReplicatorConfig tcpConfig = TcpReplicationReplicatorConfig
|
||||
final TcpReplicationConfig tcpConfig = TcpReplicationConfig
|
||||
.of(8086, new InetSocketAddress("localhost", 8087))
|
||||
.heartBeatInterval(1, SECONDS);
|
||||
|
||||
@@ -80,7 +80,7 @@ public class PostChannelCreationTest {
|
||||
|
||||
|
||||
{
|
||||
final TcpReplicationReplicatorConfig tcpConfig = TcpReplicationReplicatorConfig
|
||||
final TcpReplicationConfig tcpConfig = TcpReplicationConfig
|
||||
.of(8087, new InetSocketAddress("localhost", 8086))
|
||||
.heartBeatInterval(1, SECONDS);
|
||||
|
||||
|
||||
@@ -56,7 +56,7 @@ public class SingleMapClusterTest {
|
||||
public void setup() throws IOException {
|
||||
|
||||
{
|
||||
final TcpReplicationReplicatorConfig tcpReplicationConfig = TcpReplicationReplicatorConfig
|
||||
final TcpReplicationConfig tcpReplicationConfig = TcpReplicationConfig
|
||||
.of(8086, new InetSocketAddress("localhost", 8087))
|
||||
.heartBeatInterval(1, SECONDS);
|
||||
int maxEntrySize = 1024;
|
||||
@@ -73,7 +73,7 @@ public class SingleMapClusterTest {
|
||||
|
||||
|
||||
{
|
||||
final TcpReplicationReplicatorConfig tcpReplicationConfig = TcpReplicationReplicatorConfig
|
||||
final TcpReplicationConfig tcpReplicationConfig = TcpReplicationConfig
|
||||
.of(8087, new InetSocketAddress("localhost", 8086))
|
||||
.heartBeatInterval(1, SECONDS);
|
||||
|
||||
|
||||
+1
-1
@@ -44,7 +44,7 @@ public class TCPSocketReplicationTest3wayPutReturnsNull {
|
||||
final byte identifier,
|
||||
final int serverPort,
|
||||
final InetSocketAddress... endpoints) throws IOException {
|
||||
TcpReplicationReplicatorConfig tcpConfig = TcpReplicationReplicatorConfig.of(serverPort, endpoints);
|
||||
TcpReplicationConfig tcpConfig = TcpReplicationConfig.of(serverPort, endpoints);
|
||||
return (T) ChronicleMapBuilder.of(Integer.class, CharSequence.class)
|
||||
|
||||
.entries(1000)
|
||||
|
||||
@@ -27,7 +27,7 @@ import java.net.InetSocketAddress;
|
||||
|
||||
import static java.util.concurrent.TimeUnit.SECONDS;
|
||||
import static net.openhft.chronicle.map.Builder.getPersistenceFile;
|
||||
import static net.openhft.chronicle.map.TcpReplicationReplicatorConfig.of;
|
||||
import static net.openhft.chronicle.map.TcpReplicationConfig.of;
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertTrue;
|
||||
|
||||
@@ -43,7 +43,7 @@ public class TwoMapOnDifferentServers {
|
||||
@Before
|
||||
public void setup() throws IOException {
|
||||
|
||||
final TcpReplicationReplicatorConfig tcpConfig =
|
||||
final TcpReplicationConfig tcpConfig =
|
||||
of(8076, new InetSocketAddress("localhost", 8077))
|
||||
.heartBeatInterval(1, SECONDS);
|
||||
|
||||
|
||||
@@ -37,7 +37,7 @@ public class UDPSocketReplicationTest {
|
||||
final int identifier,
|
||||
final int udpPort) throws IOException {
|
||||
|
||||
UdpReplicationReplicatorConfig udpConfig = UdpReplicationReplicatorConfig
|
||||
UdpReplicationConfig udpConfig = UdpReplicationConfig
|
||||
.simple(Inet4Address.getByName("255.255.255.255"), udpPort);
|
||||
|
||||
return ChronicleMapBuilder.of(Integer.class, CharSequence.class)
|
||||
|
||||
@@ -27,7 +27,7 @@ import java.net.InetSocketAddress;
|
||||
|
||||
import static java.util.concurrent.TimeUnit.SECONDS;
|
||||
import static net.openhft.chronicle.map.Builder.getPersistenceFile;
|
||||
import static net.openhft.chronicle.map.TcpReplicationReplicatorConfig.of;
|
||||
import static net.openhft.chronicle.map.TcpReplicationConfig.of;
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertTrue;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user