Commit cca8fc1c by 程裕兵

feat:@EventConfig(event = CashierEvent.class, binder = "biz-kafka")

parent 6bde929f
...@@ -2,6 +2,7 @@ package com.jiejing.fitness.finance.app; ...@@ -2,6 +2,7 @@ package com.jiejing.fitness.finance.app;
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure; import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
import com.jiejing.common.config.idgen.EnableLeaseIdWorker; import com.jiejing.common.config.idgen.EnableLeaseIdWorker;
import com.jiejing.fitness.event.finance.CashierEvent;
import com.jiejing.fitness.finance.service.event.ListenerService; import com.jiejing.fitness.finance.service.event.ListenerService;
import com.jiejing.paycenter.common.event.MerchantEvent; import com.jiejing.paycenter.common.event.MerchantEvent;
import com.jiejing.paycenter.common.event.PayEvent; import com.jiejing.paycenter.common.event.PayEvent;
...@@ -29,7 +30,8 @@ import org.springframework.scheduling.annotation.EnableScheduling; ...@@ -29,7 +30,8 @@ import org.springframework.scheduling.annotation.EnableScheduling;
configs = { configs = {
@EventConfig(event = MerchantEvent.class, binder = "biz-kafka"), @EventConfig(event = MerchantEvent.class, binder = "biz-kafka"),
@EventConfig(event = PayEvent.class, binder = "biz-kafka"), @EventConfig(event = PayEvent.class, binder = "biz-kafka"),
@EventConfig(event = RefundEvent.class, binder = "biz-kafka") @EventConfig(event = RefundEvent.class, binder = "biz-kafka"),
@EventConfig(event = CashierEvent.class, binder = "biz-kafka")
}, },
listenerClass = {ListenerService.class}) listenerClass = {ListenerService.class})
@EnableFeignClients(basePackages = { @EnableFeignClients(basePackages = {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment