fix unitest for prority queue

Author: yunheli

platform-core/src/test/java/com/flow/platform/core/test/PlatformQueueTest.java

@@ -82,7 +82,7 @@ public void should_enqueue_for_rabbit_queue() throws Throwable {
     @Test
     public void should_enqueue_with_priority_in_memory_queue() throws Throwable {
         // given: queue listener
-        final int size = 4;
+        final int size = 6;
         CountDownLatch latch = new CountDownLatch(size);
         List<String> prioritizedList = new ArrayList<>(size);
 
@@ -100,17 +100,23 @@ public void should_enqueue_with_priority_in_memory_queue() throws Throwable {
         inMemoryQueue.enqueue(PriorityMessage.create("3".getBytes(), 10));
         ThreadUtil.sleep(1);
         inMemoryQueue.enqueue(PriorityMessage.create("4".getBytes(), 10));
+        ThreadUtil.sleep(1);
+        inMemoryQueue.enqueue(PriorityMessage.create("5".getBytes(), 10));
+        ThreadUtil.sleep(1);
+        inMemoryQueue.enqueue(PriorityMessage.create("6".getBytes(), 10));
         inMemoryQueue.start();
 
         // then:
         boolean await = latch.await(60, TimeUnit.SECONDS);
         Assert.assertTrue(await);
         Assert.assertEquals(size, prioritizedList.size());
 
-        Assert.assertEquals("4", prioritizedList.get(0));
-        Assert.assertEquals("3", prioritizedList.get(1));
-        Assert.assertEquals("2", prioritizedList.get(2));
-        Assert.assertEquals("1", prioritizedList.get(3));
+        Assert.assertEquals("3", prioritizedList.get(0));
+        Assert.assertEquals("4", prioritizedList.get(1));
+        Assert.assertEquals("5", prioritizedList.get(2));
+        Assert.assertEquals("6", prioritizedList.get(3));
+        Assert.assertEquals("1", prioritizedList.get(4));
+        Assert.assertEquals("2", prioritizedList.get(5));
     }
 
     @Test