pulsar_binary_protocol_spec/client_half_requests/
consumer_redeliver_unacknowledged_messages_half_request.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
use crate::commands::RedeliverUnacknowledgedMessagesCommand;

use super::HalfRequest;

pub struct ConsumerRedeliverUnacknowledgedMessagesHalfRequest {}
impl HalfRequest for ConsumerRedeliverUnacknowledgedMessagesHalfRequest {
    type Request = RedeliverUnacknowledgedMessagesCommand;
    type Error = ConsumerRedeliverUnacknowledgedMessagesHalfRequestError;
}

make_x_half_request_error!(
    ConsumerRedeliverUnacknowledgedMessages;
);