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 f4a08cffda830b789a67cd4cdaafa19513d811d7..c85f3d7cfd962009169d810d9d4374a5b3ab91ef 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");
 		}
 	}