diff --git a/crates/redis/src/lib.rs b/crates/redis/src/lib.rs index eb11869fb7..3fb789098f 100644 --- a/crates/redis/src/lib.rs +++ b/crates/redis/src/lib.rs @@ -85,10 +85,12 @@ impl TriggerExecutor for RedisTrigger { .with_context(|| anyhow!("Redis trigger failed to connect to {}", address))? .into_pubsub(); + println!("Active Channels on {address}:"); // Subscribe to channels for (channel, component) in self.channel_components.iter() { tracing::info!("Subscribing component {component:?} to channel {channel:?}"); pubsub.subscribe(channel).await?; + println!("\t{channel}: [{}]", component.join(",")); } let mut stream = pubsub.on_message();