bug fixed

This commit is contained in:
병준 박 2022-08-28 15:06:53 +00:00
parent 4637972b10
commit ee76ced214

View File

@ -110,6 +110,20 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
pool.clone(), pool.clone(),
api_config.clone(), api_config.clone(),
); );
let member_bank_deposit_event_handler = events::member_bank_deposit::event::EventHandler::new(
connection_server_broker.clone(),
queue_server_broker.clone(),
pool.clone(),
member_account_synchronizer.clone(),
api_config.clone(),
);
let member_bank_withdraw_event_handler = events::member_bank_withdraw::event::EventHandler::new(
connection_server_broker.clone(),
queue_server_broker.clone(),
pool.clone(),
member_account_synchronizer.clone(),
api_config.clone(),
);
let mut sched = tokio_cron_scheduler::JobScheduler::new().await?; let mut sched = tokio_cron_scheduler::JobScheduler::new().await?;
@ -143,6 +157,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
// member_account_service.subscribe(), // member_account_service.subscribe(),
// betting_service.subscribe(), // betting_service.subscribe(),
member_event_handler.subscribe(), member_event_handler.subscribe(),
member_bank_deposit_event_handler.subscribe(),
member_bank_withdraw_event_handler.subscribe(),
)?; )?;
sched.shutdown().await?; sched.shutdown().await?;