From e5a78c6a52fc43b424da72b0e0035d0ab50335cc Mon Sep 17 00:00:00 2001 From: karthik2804 Date: Fri, 19 Jan 2024 00:22:33 -0800 Subject: [PATCH] print active channels on redis trigger Signed-off-by: karthik2804 --- crates/redis/src/lib.rs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/crates/redis/src/lib.rs b/crates/redis/src/lib.rs index eb11869fb..3fb789098 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();