Skip to content

Commit 98b7e2e

Browse files
authored
Merge pull request #2232 from karthik2804/redis_print_channels
print active channels on redis trigger
2 parents bce0001 + e5a78c6 commit 98b7e2e

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

crates/redis/src/lib.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,10 +85,12 @@ impl TriggerExecutor for RedisTrigger {
8585
.with_context(|| anyhow!("Redis trigger failed to connect to {}", address))?
8686
.into_pubsub();
8787

88+
println!("Active Channels on {address}:");
8889
// Subscribe to channels
8990
for (channel, component) in self.channel_components.iter() {
9091
tracing::info!("Subscribing component {component:?} to channel {channel:?}");
9192
pubsub.subscribe(channel).await?;
93+
println!("\t{channel}: [{}]", component.join(","));
9294
}
9395

9496
let mut stream = pubsub.on_message();

0 commit comments

Comments
 (0)