消费数量限制

src/main/java/com/fdkankan/ucenter/mq/consumer/AutoOrderConsumer.java

@@ -42,7 +42,7 @@ public class AutoOrderConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.pay.auto-paypal:pay-auto-paypal}")
-            ,concurrency = "10"
+            ,concurrency = "1"
     )
     public void consumerQueue(Channel channel, Message message)  {
         try {

src/main/java/com/fdkankan/ucenter/mq/consumer/LaserSceneStatusConsumer.java

@@ -28,7 +28,7 @@ public class LaserSceneStatusConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.scene.laser.status:update-scene-status-ucent}")
-            ,concurrency = "10"
+            ,concurrency = "1"
     )
     public void consumerQueue(Channel channel, Message message)  {
         try {

src/main/java/com/fdkankan/ucenter/mq/consumer/OrderDownConsumer.java

@@ -44,7 +44,7 @@ public class OrderDownConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.orderPay.order-payResult:order-payResult}")
-            ,concurrency = "10"
+            ,concurrency = "1"
     )
     public void consumerQueue(Channel channel, Message message)  {
         try {

src/main/java/com/fdkankan/ucenter/mq/consumer/ScenePayStatusConsumer.java

@@ -32,7 +32,7 @@ public class ScenePayStatusConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.scene.pay-status:scene-pay-status}")
-            ,concurrency = "10"
+            ,concurrency = "1"
     )
     public void consumerQueue(Channel channel, Message message)  {
         try {