diff --git a/create_queue_db.py b/create_queue_db.py
new file mode 100644
index 0000000..6d47855
--- /dev/null
+++ b/create_queue_db.py
@@ -0,0 +1,11 @@
+import sqlite3
+
+if __name__ == '__main__':
+    con = sqlite3.connect('messages.db')
+    cur = con.cursor()
+    #cur.execute("""drop table messages""")
+    cur.execute("""create table messages( id integer primary key, message );""")
+    con.commit()
+    cur.close()
+    con.close()
+