diff --git a/src/main_chat_gateway.rs b/src/main_chat_gateway.rs
index 99ac10c7bc..a55e5ca785 100644
--- a/src/main_chat_gateway.rs
+++ b/src/main_chat_gateway.rs
@@ -32,6 +32,8 @@ async fn main() -> anyhow::Result<()> {
   let secrets = Secrets::from_file("secrets.toml")?;
 
   let mut redis_client = RedisClient::new(&secrets.redis);
+  redis_client.connect().await?;
+
   let mut twitch_client = TwitchClient::new(&secrets.twitch, redis_client);
 
   loop {
diff --git a/src/twitch_client.rs b/src/twitch_client.rs
index f2e2e253cc..8941ff00d1 100644
--- a/src/twitch_client.rs
+++ b/src/twitch_client.rs
@@ -93,8 +93,8 @@ impl TwitchClient {
           let channel = command.to_lowercase();
           let username = msg.name().trim();
           let command_payload= format!("{}|{}", username, remaining_message); // Payload: USERNAME|DATA
-          println!("Publish: {} - {}", channel, command_payload);
-          let _r = self.redis_client.publish(&channel, &command_payload).await;
+          println!("Publish: '{}' - '{}'", channel, command_payload);
+          let _r = self.redis_client.publish(&channel, &command_payload).await.expect("Should work");
         }
       },