Skip to content

Commit e5a78c6

Browse files
committed
print active channels on redis trigger
Signed-off-by: karthik2804 <[email protected]>
1 parent c25b685 commit e5a78c6

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)