pulsar-binary-protocol-spec 0.0.1

Pulsar binary protocol specification
Documentation 
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,
    ),
}