main
use rocketmq_model::common::message::message_ext::MessageExt;
pub enum ConsumeResult {
Ack {
message: MessageExt,
},
Retry {
message: MessageExt,
delay_level: i32,
},
}