1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

use crate::commands::{ConnectCommand, ConnectedCommand};

use super::Respond;

pub struct ConnectRespond {}
impl Respond for ConnectRespond {
    type Request = ConnectCommand;
    type Response = ConnectedCommand;
    type Error = ConnectRespondError;
}

make_x_respond_error!(
    Connect;
    AuthenticationError "https://github.com/apache/pulsar/blob/v2.7.0/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java#L773"
);