diff --git a/src/biz/actix_ws/server/rt_actor.rs b/src/biz/actix_ws/server/rt_actor.rs index 14207699..a21d6802 100644 --- a/src/biz/actix_ws/server/rt_actor.rs +++ b/src/biz/actix_ws/server/rt_actor.rs @@ -35,7 +35,7 @@ where fn started(&mut self, ctx: &mut Self::Context) { info!("realtime server started"); - ctx.set_mailbox_capacity(1); + ctx.set_mailbox_capacity(3000); } } impl actix::Supervised for RealtimeServerActor @@ -45,7 +45,7 @@ where { fn restarting(&mut self, ctx: &mut Context>) { error!("realtime server is restarting"); - ctx.set_mailbox_capacity(30); + ctx.set_mailbox_capacity(3000); } }