misc: persist mg test

RoyWangMe · Nov 4, 2016 · 883f5e3 · 883f5e3
1 parent f2e7760
commit 883f5e3
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 13 deletions.
diff --git a/src/main/resources/applicationContext.xml b/src/main/resources/applicationContext.xml
@@ -16,7 +16,7 @@
             http://www.springframework.org/schema/aop/spring-aop-3.1.xsd">
 
     <import resource="rabbitmq-productor.xml"/>
-    <!--<import resource="rabbitmq-consumer.xml"/>-->
+    <import resource="rabbitmq-consumer.xml"/>
     <!-- 使能AOP-->
     <aop:aspectj-autoproxy/>
     <!-- 自动装载bean使能-->

diff --git a/src/test/java/com/netease/mq/MessageSenderTest.java b/src/test/java/com/netease/mq/MessageSenderTest.java
@@ -19,23 +19,25 @@ public void before(){
 
     @Test
     public void testMessageSend() throws InterruptedException {
-        for(int i = 0 ; i < 10000 ; i++){
-            MessageSender messageSender = (MessageSender)context.getBean("messageSender");
-            byte[] bigData = new byte[1000000];
-            messageSender.sendMessage(bigData);
-            System.out.println("index :" + (i + 1));
-            Thread.sleep(100l);
+        for(int index = 0 ; index < 1000 ; index ++ ){
+            for(int i = 0 ; i < 10000 ; i++){
+                MessageSender messageSender = (MessageSender)context.getBean("messageSender");
+                byte[] bigData = new byte[1000];
+                messageSender.sendMessage(bigData);
+            }
+            Thread.sleep(10l);
         }
     }
 
     @Test
     public void testMessageSendNoDurable() throws InterruptedException {
-        for(int i = 0 ; i < 10000 ; i++){
-            MessageSender messageSender = (MessageSender)context.getBean("messageSender");
-            byte[] bigData = new byte[1000000];
-            messageSender.sendMessageNoDurable(bigData);
-            System.out.println("index :" + (i + 1));
-            Thread.sleep(100l);
+        for(int index = 0 ; index < 1000 ; index ++ ) {
+            for (int i = 0; i < 10000; i++) {
+                MessageSender messageSender = (MessageSender) context.getBean("messageSender");
+                byte[] bigData = new byte[1000];
+                messageSender.sendMessageNoDurable(bigData);
+            }
+            Thread.sleep(10l);
         }
     }