1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
use crate::{ client_half_requests::{ ConsumerFlowHalfRequest, ConsumerRedeliverUnacknowledgedMessagesHalfRequest, HalfRequest, }, client_responds::{ConsumerAckRespond, Respond}, commands::MessageCommand, }; pub type HandlerReplyConsumerFlowChannelMessage = Result<(), <ConsumerFlowHalfRequest as HalfRequest>::Error>; pub type HandlerReplyConsumerGetMessageChannelMessage = Option<MessageCommand>; pub type HandlerReplyConsumerAckChannelMessage = Result<<ConsumerAckRespond as Respond>::Response, <ConsumerAckRespond as Respond>::Error>; pub type HandlerReplyConsumerRedeliverUnacknowledgedMessagesChannelMessage = Result<(), <ConsumerRedeliverUnacknowledgedMessagesHalfRequest as HalfRequest>::Error>; pub enum HandlerReplyConsumerChannelMessage { ReplyFlow(HandlerReplyConsumerFlowChannelMessage), ReplyGetMessage(Box<HandlerReplyConsumerGetMessageChannelMessage>), ReplyAck(HandlerReplyConsumerAckChannelMessage), ReplyRedeliverUnacknowledgedMessages( HandlerReplyConsumerRedeliverUnacknowledgedMessagesChannelMessage, ), }