diff --git a/src/redis.rs b/src/redis.rs
index 149c35778..1c1d5e5e3 100644
--- a/src/redis.rs
+++ b/src/redis.rs
@@ -70,7 +70,7 @@ impl Actor for RedisActor {
             .map(|stream, act, ctx| {
                 info!("Connected to redis server: {}", act.addr);
                 act.backoff.reset();
-                act.cell = Some(act.add_framed(ctx, stream.framed(resp::RespCodec)));
+                act.cell = Some(act.add_framed(stream.framed(resp::RespCodec), ctx));
             })
             .map_err(|err, act, ctx| {
                 error!("Can not connect to redis server: {}", err);