use rocketmq_model::common::message::message_ext::MessageExt;

pub enum ConsumeResult {
    Ack {
        message: MessageExt,
    },
    Retry {
        message: MessageExt,
        delay_level: i32,
    },
}