rocketmq_client_v4/consumer/
message_handler.rs

1use crate::protocols::body::message_body::MessageBody;
2
3pub trait MessageHandler {
4    fn handle(&self, message: &MessageBody) -> impl std::future::Future<Output = ()> + Send;
5}