File tree Expand file tree Collapse file tree
apps/commerce-api/src/main/java/com/loopers/interfaces/api/listener Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -136,27 +136,6 @@ public void handleUserActionLogging(OrderCreatedEvent event) {
136136 );
137137 }
138138
139- /**
140- * 주문 생성 후 재고 변경 Kafka 이벤트 발행
141- */
142- @ Async
143- @ TransactionalEventListener (phase = TransactionPhase .AFTER_COMMIT )
144- public void handleStockChangedKafkaEvent (OrderCreatedEvent event ) {
145- log .info ("재고 변경 Kafka 이벤트 발행: orderId={}" , event .orderId ());
146-
147- try {
148- for (OrderCreatedEvent .OrderItemInfo item : event .items ()) {
149- stockChangedEventProducer .sendStockChangedEvent (
150- item .productId (),
151- item .quantity (),
152- "DECREASED"
153- );
154- }
155- } catch (Exception e ) {
156- log .error ("재고 변경 Kafka 이벤트 발행 실패: orderId={}" , event .orderId (), e );
157- }
158- }
159-
160139 @ TransactionalEventListener (phase = TransactionPhase .BEFORE_COMMIT )
161140 public void handleStockChangedOutboxEvent (OrderCreatedEvent event ) {
162141 log .info ("재고 변경 Outbox 이벤트 저장: orderId={}" , event .orderId ());
You can’t perform that action at this time.
0 commit comments