diff --git a/src/server.js b/src/server.js
index 0ef4f80..3314c9a 100644
--- a/src/server.js
+++ b/src/server.js
@@ -10,9 +10,7 @@ const config = require("./config");
 
 // Send Speech to Text to Redis Stream
 const sendTranscriptEvent = async (streamKey, type, text) => {
-    await redis.client.connect().catch(console.error);
-
-    await redis.xAdd(
+    await redis.client.xAdd(
         streamKey,
         '*',
         {
@@ -21,8 +19,6 @@ const sendTranscriptEvent = async (streamKey, type, text) => {
         }
     )
 
-    await redis.client.quit();
-
     console.log("Transcript added to stream");
 }
 
@@ -30,7 +26,7 @@ const sendTranscriptEvent = async (streamKey, type, text) => {
 const processor = async (group, consumer, streamKey) => {
     await redis.client.connect().catch(console.error);
 
-    sendTranscriptEvent(streamKey, "TEST", "TEST");
+    sendTranscriptEvent("speech:events", "TEST", "TEST");
 
     while (true) {
         const res = await redis.client.xReadGroup(