less-logs
This commit is contained in:
parent
5bc4f1ef5c
commit
6b20322edf
|
@ -77,13 +77,8 @@ async fn connect_handler(
|
|||
}
|
||||
|
||||
while let Some(msg) = pubsub.on_message().next().await {
|
||||
println!("Received a message from Redis"); // Add this line
|
||||
|
||||
let message_str: String = msg.get_payload().unwrap();
|
||||
println!("Message payload: {}", message_str); // Add this line
|
||||
|
||||
let message_data: RedisMessageData = serde_json::from_str(&message_str).unwrap();
|
||||
println!("Deserialized message data: {:?}", message_data.clone()); // Add this line
|
||||
|
||||
if msg.get_channel_name().starts_with("chat:")
|
||||
|| msg.get_channel_name().starts_with("followers:")
|
||||
|
|
Loading…
Reference in New Issue
Block a user