Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

updated test to new API

Browse Source
This commit is contained in:
Rob Austin
2014-12-15 12:29:55 +00:00
parent 76cbbc19ff
commit 4761a8ac61
1 changed files with 42 additions and 45 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/test/java/eg/TestNesterInterfaceMarshal.java
+42 -45
View File
@@ -3,7 +3,6 @@ package eg;
import net.openhft.chronicle.hash.replication.TcpTransportAndNetworkConfig;
import net.openhft.chronicle.map.ChronicleMap;
import net.openhft.chronicle.map.ChronicleMapBuilder;
import net.openhft.lang.model.DataValueClasses;
import org.junit.Assert;
import org.junit.Test;
@@ -16,59 +15,57 @@ import java.util.concurrent.TimeUnit;
public class TestNesterInterfaceMarshal {
/**
* Test that both maps are created first and then populated the first map so that second will
* get the contents
*
* @throws Exception
*/
@Test
public void testReplicatedMap() throws Exception {
ChronicleMap<CharSequence, TestIntrumentVOInterface> map = createReplicatedMap1();
ChronicleMap<CharSequence, TestIntrumentVOInterface> replicatedMap = createReplicatedMap2();
/**
* Test that both maps are created first and then populated the first map so that second will get the contents
* @throws Exception
*/
@Test
public void testReplicatedMap() throws Exception {
ChronicleMap<CharSequence,TestIntrumentVOInterface> map =createReplicatedMap1();
ChronicleMap<CharSequence,TestIntrumentVOInterface> replicatedMap=createReplicatedMap2();
//Store some data into MAP1
TestIntrumentVOInterface intrumentVOInterface = map.newValueInstance();
intrumentVOInterface.setSymbol("Flyer");
intrumentVOInterface.setCurrencyCode("USA");
intrumentVOInterface.setSizeOfInstrumentIDArray(2);
TestIntrumentVOInterface.TestInstrumentIDVOInterface instrumentIDVOInterface = intrumentVOInterface.getInstrumentIDAt(0);
instrumentIDVOInterface.setIdSource("CUSIP");
instrumentIDVOInterface.setSecurityId("TEST");
intrumentVOInterface.setInstrumentIDAt(0, instrumentIDVOInterface);
map.put("KEY1", intrumentVOInterface);
//Store some data into MAP1
TestIntrumentVOInterface intrumentVOInterface= DataValueClasses.newDirectInstance(TestIntrumentVOInterface.class);
intrumentVOInterface.setSymbol("FIXFlyer");
intrumentVOInterface.setCurrencyCode("USA");
intrumentVOInterface.setSizeOfInstrumentIDArray(2);
TestIntrumentVOInterface.TestInstrumentIDVOInterface instrumentIDVOInterface= intrumentVOInterface.getInstrumentIDAt(0);
instrumentIDVOInterface.setIdSource("CUSIP");
instrumentIDVOInterface.setSecurityId("TEST");
intrumentVOInterface.setInstrumentIDAt(0,instrumentIDVOInterface);
map.put("KEY1",intrumentVOInterface);
Assert.assertNotNull(map);
Assert.assertNotNull(replicatedMap);
Assert.assertNotNull(map);
Assert.assertNotNull(replicatedMap);
int t = 0;
for (; t < 5000; t++) {
if (map.equals(replicatedMap))
break;
Thread.sleep(1);
}
Assert.assertEquals(map, replicatedMap);
Assert.assertTrue(!replicatedMap.isEmpty());
System.out.println(map.get("KEY1"));
System.out.println(replicatedMap.get("KEY1"));
map.close();
replicatedMap.close();
int t = 0;
for (; t < 5000; t++) {
if (map.equals(replicatedMap))
break;
Thread.sleep(1);
}
Assert.assertEquals(map, replicatedMap);
Assert.assertTrue(!replicatedMap.isEmpty());
System.out.println(map.get("KEY1"));
System.out.println(replicatedMap.get("KEY1"));
map.close();
replicatedMap.close();
}
protected ChronicleMap createReplicatedMap1() {
ChronicleMap chronicleMap = null;
TcpTransportAndNetworkConfig tcpTransportAndNetworkConfig=TcpTransportAndNetworkConfig.of(8076).heartBeatInterval(1L, TimeUnit.SECONDS);
TcpTransportAndNetworkConfig tcpTransportAndNetworkConfig = TcpTransportAndNetworkConfig.of(8076).heartBeatInterval(1L, TimeUnit.SECONDS);
try {
ChronicleMapBuilder builder = ChronicleMapBuilder.of(CharSequence.class, TestIntrumentVOInterface.class)
.entries(5000L).entrySize(2000)
@@ -86,14 +83,14 @@ public class TestNesterInterfaceMarshal {
protected ChronicleMap createReplicatedMap2() {
ChronicleMap chronicleMap = null;
TcpTransportAndNetworkConfig tcpTransportAndNetworkConfig=TcpTransportAndNetworkConfig.of(8077,new InetSocketAddress("127.0.0.1",8076)).heartBeatInterval(1L, TimeUnit.SECONDS);
TcpTransportAndNetworkConfig tcpTransportAndNetworkConfig = TcpTransportAndNetworkConfig.of(8077, new InetSocketAddress("127.0.0.1", 8076)).heartBeatInterval(1L, TimeUnit.SECONDS);
try {
ChronicleMapBuilder builder = ChronicleMapBuilder.of(CharSequence.class, TestIntrumentVOInterface.class)
.putReturnsNull(true)
.removeReturnsNull(true)
.entries(5000L).entrySize(2000)
.replication((byte)2,tcpTransportAndNetworkConfig) ;
.replication((byte) 2, tcpTransportAndNetworkConfig);
chronicleMap = builder.create();