diff --git a/example.env b/example.env
index 498c5ec..83f1e15 100644
--- a/example.env
+++ b/example.env
@@ -12,4 +12,5 @@ JTW_SECRET=SECRETHERE
 # Resets the database with models defined under src/models/
 FORCE_DB_SYNC=true # Use false during production
 
-NODE_ENV=development
\ No newline at end of file
+NODE_ENV=development
+DEVICE_ID=backend
\ No newline at end of file
diff --git a/src/models/index.js b/src/models/index.js
index f1406d0..0dd6460 100644
--- a/src/models/index.js
+++ b/src/models/index.js
@@ -52,6 +52,28 @@ redis.client = Redis.createClient({
 redis.client.on('error', (err) => console.error('Redis error:', err));
 
 
+
+const initializeStreams = async () => {
+    try {
+        await redis.client.connect().catch(console.error);
+        
+        console.log("Initializing Redis Streams...");
+
+        // Create transcriptions streams consumer group
+        await client.xGroupCreate("communication", "mtf-devices", '0', {MKSTREAM: true});
+
+        console.log("Created consumer group: mtf-devices (communication)");
+    } catch (err) {
+        if (err.message.includes('BUSYGROUP')) {
+            console.log("Consumer group already exists: mtf-devices");
+        } else {
+            console.error(err);
+        }
+    }
+
+    const deviceIds = [""]
+}
+
 module.exports = {
     db,
     redis