diff --git a/core/tasks/handler/worker.go b/core/tasks/handler/worker.go
index 62ef5c6dd..59918ee34 100644
--- a/core/tasks/handler/worker.go
+++ b/core/tasks/handler/worker.go
@@ -620,6 +620,17 @@ func handleMsgEvent(ctx context.Context, rt *runtime.Runtime, event *MsgEvent, s
 			if err != nil {
 				return errors.Wrapf(err, "error creating flow contact")
 			}
+
+			msgIn := flows.NewMsgIn(event.MsgUUID, event.URN, channel.ChannelReference(), event.Text, event.Attachments)
+			msgIn.SetExternalID(string(event.MsgExternalID))
+			msgIn.SetID(event.MsgID)
+
+			err = handleAsInbox(ctx, rt, oa, contact, msgIn, topupID, nil)
+			if err != nil {
+				return errors.Wrapf(err, "error handling inbox message")
+			}
+			return nil
+
 		}
 	}