.

src/main/java/com/izouma/nineth/service/CollectionService.java

@@ -352,6 +352,7 @@ public class CollectionService {
             redisTemplate.opsForValue().set("collectionStock::" + id, collectionRepo.getStock(id));
         }
         Long stock = redisTemplate.opsForValue().increment("collectionStock::" + id, number);
+        rocketMQTemplate.convertAndSend(generalProperties.getUpdateStockTopic(), id);
         return stock;
     }
 
@@ -369,7 +370,7 @@ public class CollectionService {
             redisTemplate.opsForValue().set("collectionSale::" + id, collectionRepo.getSale(id));
         }
         Long sale = redisTemplate.opsForValue().increment("collectionSale::" + id, number);
-        rocketMQTemplate.convertAndSend(generalProperties.getUpdateSaleGroup(), id);
+        rocketMQTemplate.convertAndSend(generalProperties.getUpdateSaleTopic(), id);
         return sale;
     }
 
@@ -378,7 +379,7 @@ public class CollectionService {
             redisTemplate.opsForValue().set("collectionSale::" + id, collectionRepo.getSale(id));
         }
         Long sale = redisTemplate.opsForValue().decrement("collectionSale::" + id, number);
-        rocketMQTemplate.convertAndSend(generalProperties.getUpdateSaleGroup(), id);
+        rocketMQTemplate.convertAndSend(generalProperties.getUpdateSaleTopic(), id);
         return sale;
     }