Skip to content

Commit 2c72537

Browse files
committed
Prevent resend attempts when the session is not connected
1 parent 1a776a8 commit 2c72537

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

crates/hotfix/src/session.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -361,6 +361,10 @@ impl<A: Application<M>, M: FixMessage, S: MessageStore> Session<A, M, S> {
361361
}
362362

363363
async fn on_resend_request(&mut self, message: &Message) -> Result<()> {
364+
if !self.state.is_connected() {
365+
warn!("received resend request while disconnected, ignoring");
366+
}
367+
364368
let begin_seq_number: u64 = match message.get(fix44::BEGIN_SEQ_NO) {
365369
Ok(seq_number) => seq_number,
366370
Err(_) => {

0 commit comments

Comments
 (0)