diff --git a/src/redis.rs b/src/redis.rs index 2fd6ab8c4..c9705458a 100644 --- a/src/redis.rs +++ b/src/redis.rs @@ -37,10 +37,13 @@ impl RedisActor { pub fn start>(addr: S) -> Addr { let addr = addr.into(); + let mut backoff = ExponentialBackoff::default(); + backoff.max_elapsed_time = None; + Supervisor::start(|_| RedisActor { addr: addr, cell: None, - backoff: ExponentialBackoff::default(), + backoff: backoff, queue: VecDeque::new(), }) }