diff --git a/job.go b/job.go
index 2aab1f2..bb6467a 100644
--- a/job.go
+++ b/job.go
@@ -566,8 +566,8 @@ func jobBackupImport(j Job) {
 			if err != nil {
 				return
 			}
-			for _, m := range bkp.Messages {
-				_, err = addObjMsg(m.ID64, m.ChatID64, m.UserID64, m.SenderUserID64, m.Date, m.Text)
+			for _, msg := range bkp.Messages {
+				MQCWMsgQueue <- msg
 			}
 
 			m := TGCommand{