[incubator-dubbo] branch 2.6.x updated: Fix random ut falling in DubboMonitorTest (#3336)

[iluo]

This is an automated email from the ASF dual-hosted git repository.

iluo pushed a commit to branch 2.6.x
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git


The following commit(s) were added to refs/heads/2.6.x by this push:
     new 43d8620  Fix random ut falling in DubboMonitorTest (#3336)
43d8620 is described below

commit 43d8620cee20eaa7a9f1194f6f2f2650367673c7
Author: Yuhao Bi <byh0...@gmail.com>
AuthorDate: Mon Jan 28 17:04:07 2019 +0800

    Fix random ut falling in DubboMonitorTest (#3336)
---
 .../dubbo/monitor/dubbo/DubboMonitorTest.java      | 27 +++++++++++-----------
 1 file changed, 14 insertions(+), 13 deletions(-)

diff --git 
a/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitorTest.java
 
b/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitorTest.java
index 8d5ec57..d2a0e29 100644
--- 
a/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitorTest.java
+++ 
b/dubbo-monitor/dubbo-monitor-default/src/test/java/com/alibaba/dubbo/monitor/dubbo/DubboMonitorTest.java
@@ -103,22 +103,23 @@ public class DubboMonitorTest {
                 .addParameter(MonitorService.CONCURRENT, 1)
                 .addParameter(MonitorService.MAX_CONCURRENT, 1);
         monitor.collect(statistics);
+        monitor.send();
         while (lastStatistics == null) {
             Thread.sleep(10);
         }
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.APPLICATION), 
"morgan");
-        Assert.assertEquals(lastStatistics.getProtocol(), "dubbo");
-        Assert.assertEquals(lastStatistics.getHost(), "10.20.153.10");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.APPLICATION), 
"morgan");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.INTERFACE), 
"MemberService");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.METHOD), 
"findPerson");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.CONSUMER), 
"10.20.153.11");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.SUCCESS), "1");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.FAILURE), "0");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.ELAPSED), "3");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.MAX_ELAPSED), 
"3");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.CONCURRENT), 
"1");
-        
Assert.assertEquals(lastStatistics.getParameter(MonitorService.MAX_CONCURRENT), 
"1");
+        Assert.assertEquals("morgan", 
lastStatistics.getParameter(MonitorService.APPLICATION));
+        Assert.assertEquals("dubbo", lastStatistics.getProtocol());
+        Assert.assertEquals("10.20.153.10", lastStatistics.getHost());
+        Assert.assertEquals("morgan", 
lastStatistics.getParameter(MonitorService.APPLICATION));
+        Assert.assertEquals("MemberService", 
lastStatistics.getParameter(MonitorService.INTERFACE));
+        Assert.assertEquals("findPerson", 
lastStatistics.getParameter(MonitorService.METHOD));
+        Assert.assertEquals("10.20.153.11", 
lastStatistics.getParameter(MonitorService.CONSUMER));
+        Assert.assertEquals("1", 
lastStatistics.getParameter(MonitorService.SUCCESS));
+        Assert.assertEquals("0", 
lastStatistics.getParameter(MonitorService.FAILURE));
+        Assert.assertEquals("3", 
lastStatistics.getParameter(MonitorService.ELAPSED));
+        Assert.assertEquals("3", 
lastStatistics.getParameter(MonitorService.MAX_ELAPSED));
+        Assert.assertEquals("1", 
lastStatistics.getParameter(MonitorService.CONCURRENT));
+        Assert.assertEquals("1", 
lastStatistics.getParameter(MonitorService.MAX_CONCURRENT));
         monitor.destroy();
     }