Trait MessageHandler

pub trait MessageHandler: Send + Sync {
    // Required method
    fn handle_message(
        &self,
        topic: &str,
        message: &Message,
    ) -> Result<(), NerveError>;
}

Message handler interface

Required Methods

fn handle_message( &self, topic: &str, message: &Message, ) -> Result<(), NerveError>

Handle a message

Implementors