mirror of
https://github.com/actix/actix-extras.git
synced 2024-11-24 07:53:00 +01:00
commit
28b50a3755
@ -69,7 +69,7 @@ impl Actor for RedisActor {
|
|||||||
Err(err) => {
|
Err(err) => {
|
||||||
error!("Can not connect to redis server: {}", err);
|
error!("Can not connect to redis server: {}", err);
|
||||||
// re-connect with backoff time.
|
// re-connect with backoff time.
|
||||||
// we stop currect context, supervisor will restart it.
|
// we stop current context, supervisor will restart it.
|
||||||
if let Some(timeout) = act.backoff.next_backoff() {
|
if let Some(timeout) = act.backoff.next_backoff() {
|
||||||
ctx.run_later(timeout, |_, ctx| ctx.stop());
|
ctx.run_later(timeout, |_, ctx| ctx.stop());
|
||||||
} else {
|
} else {
|
||||||
@ -80,7 +80,7 @@ impl Actor for RedisActor {
|
|||||||
.map_err(|err, act, ctx| {
|
.map_err(|err, act, ctx| {
|
||||||
error!("Can not connect to redis server: {}", err);
|
error!("Can not connect to redis server: {}", err);
|
||||||
// re-connect with backoff time.
|
// re-connect with backoff time.
|
||||||
// we stop currect context, supervisor will restart it.
|
// we stop current context, supervisor will restart it.
|
||||||
if let Some(timeout) = act.backoff.next_backoff() {
|
if let Some(timeout) = act.backoff.next_backoff() {
|
||||||
ctx.run_later(timeout, |_, ctx| ctx.stop());
|
ctx.run_later(timeout, |_, ctx| ctx.stop());
|
||||||
} else {
|
} else {
|
||||||
|
Loading…
Reference in New Issue
Block a user