From 8d36fa8cc091391fab6c53fbe4819faa54a35d4d Mon Sep 17 00:00:00 2001
From: lfp1979 <104354500@qq.com>
Date: Fri, 13 Aug 2021 07:53:06 +0000
Subject: [PATCH] =?UTF-8?q?update=20src/main/java/com/itstyle/seckill/queu?=
 =?UTF-8?q?e/activemq/ActiveMQConsumer.java.=20=E9=9A=BE=E9=81=93=E6=B2=A1?=
 =?UTF-8?q?=E4=BA=BA=E5=8F=91=E7=8E=B0=E6=B5=8F=E8=A7=88=E5=99=A8=E6=97=A0?=
 =?UTF-8?q?=E6=B3=95=E6=94=B6=E5=88=B0=E2=80=9C=E7=A7=92=E6=9D=80=E6=88=90?=
 =?UTF-8?q?=E5=8A=9F=E2=80=9D=E7=9A=84=E9=80=9A=E7=9F=A5=E5=90=97=EF=BC=9F?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98=E5=B0=B1=E5=9C=A8=E8=BF=99=E9=87=8C=EF=BC=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/itstyle/seckill/queue/activemq/ActiveMQConsumer.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/itstyle/seckill/queue/activemq/ActiveMQConsumer.java b/src/main/java/com/itstyle/seckill/queue/activemq/ActiveMQConsumer.java
index f4a08cf..c85f3d7 100644
--- a/src/main/java/com/itstyle/seckill/queue/activemq/ActiveMQConsumer.java
+++ b/src/main/java/com/itstyle/seckill/queue/activemq/ActiveMQConsumer.java
@@ -29,9 +29,9 @@ public class ActiveMQConsumer {
 		String[] array = message.split(";");
 		Result result = seckillService.startSeckilDBPCC_TWO(Long.parseLong(array[0]), Long.parseLong(array[1]));
 		if(result.equals(Result.ok(SeckillStatEnum.SUCCESS))){
-			WebSocketServer.sendInfo(array[0], "秒杀成功");
+			WebSocketServer.sendInfo("秒杀成功",array[1]);
 		}else{
-			WebSocketServer.sendInfo(array[0], "秒杀失败");
+			WebSocketServer.sendInfo("秒杀失败",array[1]);
 			redisUtil.cacheValue(array[0], "ok");
 		}
 	}
-- 
Gitee