diff --git a/Cargo.lock b/Cargo.lock
index d3a545b7..3447c8ce 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -8696,6 +8696,7 @@ dependencies = [
  "jsonrpsee",
  "lazy_static",
  "log",
+ "rocksdb",
  "schnorr-signatures",
  "serai-db",
  "serai-primitives",
diff --git a/message-queue/Cargo.toml b/message-queue/Cargo.toml
index 9f366887..9167b71c 100644
--- a/message-queue/Cargo.toml
+++ b/message-queue/Cargo.toml
@@ -32,7 +32,8 @@ schnorr-signatures = { path = "../crypto/schnorr" }
 log = "0.4"
 tokio = { version = "1", features = ["full"] }
 
-serai-db = { path = "../common/db" }
+serai-db = { path = "../common/db", features = ["rocksdb"] }
+rocksdb = "0.21"
 
 serai-primitives = { path = "../substrate/primitives" }
 
diff --git a/message-queue/src/main.rs b/message-queue/src/main.rs
index bf94ccd5..c2cff525 100644
--- a/message-queue/src/main.rs
+++ b/message-queue/src/main.rs
@@ -16,10 +16,12 @@ use messages::*;
 mod queue;
 use queue::Queue;
 
+type Db = Arc<rocksdb::TransactionDB>;
+
 lazy_static::lazy_static! {
   static ref KEYS: Arc<RwLock<HashMap<Service, <Ristretto as Ciphersuite>::G>>> =
     Arc::new(RwLock::new(HashMap::new()));
-  static ref QUEUES: Arc<RwLock<HashMap<Service, RwLock<Queue<serai_db::MemDb>>>>> =
+  static ref QUEUES: Arc<RwLock<HashMap<Service, RwLock<Queue<Db>>>>> =
     Arc::new(RwLock::new(HashMap::new()));
 }
 
@@ -97,8 +99,8 @@ fn ack_message(service: Service, id: u64, _signature: SchnorrSignature<Ristretto
 #[tokio::main]
 async fn main() {
   // Open the DB
-  // TODO
-  let db = serai_db::MemDb::new();
+  let db =
+    Arc::new(rocksdb::TransactionDB::open_default(std::env::var("DB_PATH").unwrap()).unwrap());
 
   let read_key = |str| {
     let Ok(key) = std::env::var(str) else { None? };
@@ -132,7 +134,8 @@ async fn main() {
   // Start server
   let builder = ServerBuilder::new();
   // TODO: Set max request/response size
-  let listen_on: &[std::net::SocketAddr] = &["0.0.0.0".parse().unwrap()];
+  // 5132 ^ ((b'M' << 8) | b'Q')
+  let listen_on: &[std::net::SocketAddr] = &["0.0.0.0:2287".parse().unwrap()];
   let server = builder.build(listen_on).await.unwrap();
 
   let mut module = RpcModule::new(());
@@ -165,5 +168,7 @@ async fn main() {
       Ok(())
     })
     .unwrap();
-  server.start(module).unwrap();
+
+  // Run until stopped, which it never will
+  server.start(module).unwrap().stopped().await;
 }