Commit a3ef3f40 by 程裕兵

feat:event

parent bf1245d2
...@@ -5,8 +5,10 @@ import com.jiejing.common.config.idgen.EnableLeaseIdWorker; ...@@ -5,8 +5,10 @@ import com.jiejing.common.config.idgen.EnableLeaseIdWorker;
import com.jiejing.fitness.event.finance.CashierEvent; 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.MerchantSubChannelEvent;
import com.jiejing.paycenter.common.event.PayEvent; import com.jiejing.paycenter.common.event.PayEvent;
import com.jiejing.paycenter.common.event.RefundEvent; import com.jiejing.paycenter.common.event.RefundEvent;
import com.jiejing.workflow.event.DelayTaskEvent;
import com.xiaomai.event.annotation.EnableEventBinding; import com.xiaomai.event.annotation.EnableEventBinding;
import com.xiaomai.event.annotation.EventConfig; import com.xiaomai.event.annotation.EventConfig;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
...@@ -31,7 +33,9 @@ import org.springframework.scheduling.annotation.EnableScheduling; ...@@ -31,7 +33,9 @@ import org.springframework.scheduling.annotation.EnableScheduling;
@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") @EventConfig(event = CashierEvent.class, binder = "biz-kafka"),
@EventConfig(event = DelayTaskEvent.class, binder = "biz-kafka"),
@EventConfig(event = MerchantSubChannelEvent.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