diff --git a/queue/queue_manager.go b/queue/queue_manager.go
index 97ce1a8..5c332b3 100644
--- a/queue/queue_manager.go
+++ b/queue/queue_manager.go
@@ -1049,7 +1049,7 @@ func (queueManager *QueueManager) ReportingAttempt(attemptId int64, result model
 			if err != nil {
 				attempt.Log(err.Error())
 			}
-			if err != errNotFoundConnection {
+			if err != errNotFoundConnection && attempt.state != model.MemberStateProcessing {
 				return err
 			}
 		}