diff --git a/src/biz/actix_ws/server/rt_actor.rs b/src/biz/actix_ws/server/rt_actor.rs index 9479cf4d..4471aae0 100644 --- a/src/biz/actix_ws/server/rt_actor.rs +++ b/src/biz/actix_ws/server/rt_actor.rs @@ -34,7 +34,7 @@ where type Context = Context; fn started(&mut self, ctx: &mut Self::Context) { - ctx.set_mailbox_capacity(3000); + ctx.set_mailbox_capacity(6000); } } impl actix::Supervised for RealtimeServerActor @@ -44,7 +44,7 @@ where { fn restarting(&mut self, ctx: &mut Context>) { error!("realtime server is restarting"); - ctx.set_mailbox_capacity(3000); + ctx.set_mailbox_capacity(6000); } }