fix apache#195 optimize message unit test

github-ygy · Mar 1, 2019 · c176dbe · c176dbe
1 parent 57c5247
commit c176dbe
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/core/src/test/java/com/alibaba/fescar/core/protocol/MessageFutureTest.java b/core/src/test/java/com/alibaba/fescar/core/protocol/MessageFutureTest.java
@@ -59,7 +59,7 @@ public void testIsTimeOut() throws Exception {
         MessageFuture messageFuture=new MessageFuture();
         messageFuture.setTimeout(TIME_OUT_FIELD);
         Assert.assertTrue(!messageFuture.isTimeout());
-        Thread.sleep(TIME_OUT_FIELD);
+        Thread.sleep(TIME_OUT_FIELD +1);
         Assert.assertTrue(messageFuture.isTimeout());
 
     }

diff --git a/core/src/test/java/com/alibaba/fescar/core/protocol/RpcMessageTest.java b/core/src/test/java/com/alibaba/fescar/core/protocol/RpcMessageTest.java
@@ -59,10 +59,11 @@ public void testFieldGetSetFromJson() {
 
     @Test
     public void testGetNextMessageId() {
-        Assert.assertEquals(1, RpcMessage.getNextMessageId());
-        Assert.assertEquals(2, RpcMessage.getNextMessageId());
-        Assert.assertEquals(3, RpcMessage.getNextMessageId());
-        Assert.assertEquals(4, RpcMessage.getNextMessageId());
-        Assert.assertEquals(5, RpcMessage.getNextMessageId());
+        long startMessageId=RpcMessage.getNextMessageId();
+        Assert.assertEquals(1+startMessageId, RpcMessage.getNextMessageId());
+        Assert.assertEquals(2+startMessageId, RpcMessage.getNextMessageId());
+        Assert.assertEquals(3+startMessageId, RpcMessage.getNextMessageId());
+        Assert.assertEquals(4+startMessageId, RpcMessage.getNextMessageId());
+        Assert.assertEquals(5+startMessageId, RpcMessage.getNextMessageId());
     }
 }