diff --git a/fileTransfer2/connect/utils_test.go b/fileTransfer2/connect/utils_test.go
index b6850c7962f73cb7a1d8c5c100367e33ff047bf0..43eaaa09400b2e0d3feeafd96a46a8809011e6cb 100644
--- a/fileTransfer2/connect/utils_test.go
+++ b/fileTransfer2/connect/utils_test.go
@@ -102,6 +102,8 @@ func (m *mockCmix) DeleteFingerprint(_ *id.ID, fp format.Fingerprint) {
 	m.handler.Unlock()
 }
 
+func (m *mockCmix) CheckInProgressMessages() {}
+
 func (m *mockCmix) IsHealthy() bool {
 	return m.health
 }
diff --git a/fileTransfer2/e2e/utils_test.go b/fileTransfer2/e2e/utils_test.go
index 7b5a08015dab748e1b2969831300de146b52b716..30b9edd67c1daccf35854efe661f9a174b5f64f8 100644
--- a/fileTransfer2/e2e/utils_test.go
+++ b/fileTransfer2/e2e/utils_test.go
@@ -101,6 +101,8 @@ func (m *mockCmix) DeleteFingerprint(_ *id.ID, fp format.Fingerprint) {
 	m.handler.Unlock()
 }
 
+func (m *mockCmix) CheckInProgressMessages() {}
+
 func (m *mockCmix) IsHealthy() bool {
 	return m.health
 }
diff --git a/fileTransfer2/e2e/wrapper.go b/fileTransfer2/e2e/wrapper.go
index b53cffe55da7edd1d7d2ea32dbdab762282acf4f..3f8247de26e37ea2a1dee896a2a40211385c4a9c 100644
--- a/fileTransfer2/e2e/wrapper.go
+++ b/fileTransfer2/e2e/wrapper.go
@@ -113,7 +113,8 @@ func (w *Wrapper) RegisterSentProgressCallback(tid *ftCrypto.TransferID,
 // addEndMessageToCallback adds the sending of an E2E message when the transfer
 // completed to the callback. If NotifyUponCompletion is not set, then the
 // message is not sent.
-func (w *Wrapper) addEndMessageToCallback(progressCB ft.SentProgressCallback) ft.SentProgressCallback {
+func (w *Wrapper) addEndMessageToCallback(
+	progressCB ft.SentProgressCallback) ft.SentProgressCallback {
 	if !w.p.NotifyUponCompletion {
 		return progressCB
 	}
diff --git a/fileTransfer2/groupChat/utils_test.go b/fileTransfer2/groupChat/utils_test.go
index f7db390d5c75b1286e39eccfd7be779031a2873d..0c0b21bffae44be1b49a0c18892e33cc6c18ed8d 100644
--- a/fileTransfer2/groupChat/utils_test.go
+++ b/fileTransfer2/groupChat/utils_test.go
@@ -99,6 +99,8 @@ func (m *mockCmix) DeleteFingerprint(_ *id.ID, fp format.Fingerprint) {
 	m.handler.Unlock()
 }
 
+func (m *mockCmix) CheckInProgressMessages() {}
+
 func (m *mockCmix) IsHealthy() bool {
 	return m.health
 }
diff --git a/fileTransfer2/manager.go b/fileTransfer2/manager.go
index 3b4bdbccd036290c86e61d78f5e2f62a25c00632..f2dfd75e4d0fae4a3ea36557d58fbbe9de12eb61 100644
--- a/fileTransfer2/manager.go
+++ b/fileTransfer2/manager.go
@@ -137,6 +137,7 @@ type Cmix interface {
 	AddFingerprint(identity *id.ID, fingerprint format.Fingerprint,
 		mp message.Processor) error
 	DeleteFingerprint(identity *id.ID, fingerprint format.Fingerprint)
+	CheckInProgressMessages()
 	IsHealthy() bool
 	AddHealthCallback(f func(bool)) uint64
 	RemoveHealthCallback(uint64)
@@ -567,4 +568,6 @@ func (m *manager) addFingerprints(rt *store.ReceivedTransfer) {
 				"%s: %+v", rt.TransferID(), err)
 		}
 	}
+
+	m.cmix.CheckInProgressMessages()
 }
diff --git a/fileTransfer2/utils_test.go b/fileTransfer2/utils_test.go
index cd57f2aa5b93938ca8b9b4c0221c6e4c2dafd3bb..ef5722da07aa7e107c5272c5f998340129dafa20 100644
--- a/fileTransfer2/utils_test.go
+++ b/fileTransfer2/utils_test.go
@@ -155,6 +155,8 @@ func (m *mockCmix) DeleteFingerprint(_ *id.ID, fp format.Fingerprint) {
 	delete(m.handler.processorMap, fp)
 }
 
+func (m *mockCmix) CheckInProgressMessages() {}
+
 func (m *mockCmix) IsHealthy() bool {
 	return m.health
 }