diff --git a/migrate_cached_request_data.py b/migrate_cached_request_data.py
new file mode 100644
index 0000000..5870aff
--- /dev/null
+++ b/migrate_cached_request_data.py
@@ -0,0 +1,6 @@
+from queue_message.CookiesPublisher import MORNING_DATA_CACHE_2, MORNING_DATA_CACHE
+from workers.MessagerTransporter import migrate_message_to_queue
+
+if __name__ == '__main__':
+    migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_2)
+    migrate_message_to_queue(from_queue=MORNING_DATA_CACHE)
diff --git a/workers/MessagerTransporter.py b/workers/MessagerTransporter.py
index b824136..8292136 100644
--- a/workers/MessagerTransporter.py
+++ b/workers/MessagerTransporter.py
@@ -39,9 +39,18 @@ class MessageTransporter(threading.Thread):
             exit(0)
 
 
-if __name__ == '__main__':
-    cookiesPublisher = CookiesPublisher(queue_name="MORNING_DATA_CACHE_BAK")
+def migrate_message_to_queue(from_queue, to_queue="MORNING_DATA_CACHE_BAK"):
+    cookiesPublisher = CookiesPublisher(queue_name=to_queue)
     cookiesPublisher.set_up_connection()
-    message_transporter = MessageTransporter(cookiesPublisher=cookiesPublisher, queue_to_listen=MORNING_DATA_CACHE)
+    message_transporter = MessageTransporter(cookiesPublisher=cookiesPublisher, queue_to_listen=from_queue)
     message_transporter.set_up_connection()
     message_transporter.listen_to_queue()
+
+
+if __name__ == '__main__':
+    migrate_message_to_queue(from_queue=MORNING_DATA_CACHE_2)
+    # cookiesPublisher = CookiesPublisher(queue_name="MORNING_DATA_CACHE_BAK")
+    # cookiesPublisher.set_up_connection()
+    # message_transporter = MessageTransporter(cookiesPublisher=cookiesPublisher, queue_to_listen=MORNING_DATA_CACHE)
+    # message_transporter.set_up_connection()
+    # message_transporter.listen_to_queue()