Skip to content

Commit cbdd411

Browse files
authored
chore: add error message for reconnect failure (#2253)
1 parent 1e4671a commit cbdd411

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

crates/pubsub/src/service.rs

+2
Original file line numberDiff line numberDiff line change
@@ -206,13 +206,15 @@ impl<T: PubSubConnect> PubSubService<T> {
206206
break Err(e)
207207
}
208208
} else if let Err(e) = self.reconnect().await {
209+
error!("Reconnect failed, shutting down: {e}");
209210
break Err(e)
210211
}
211212
}
212213

213214
_ = &mut self.handle.error => {
214215
error!("Pubsub service backend error.");
215216
if let Err(e) = self.reconnect().await {
217+
error!("Reconnect failed, shutting down: {e}");
216218
break Err(e)
217219
}
218220
}

0 commit comments

Comments
 (0)