sova-rabbit 0.1.1

RabbitMQ / AMQP broker plugin for Sova (raw publish/consume + fake)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Rabbit errors.

use thiserror::Error;

#[derive(Debug, Error)]
pub enum RabbitError {
    #[error("rabbit: {0}")]
    Msg(String),
    #[error("rabbit not connected")]
    NotConnected,
    #[error("rabbit plugin not installed")]
    NotInstalled,
}

impl From<RabbitError> for sova_core::Error {
    fn from(value: RabbitError) -> Self {
        sova_core::Error::Internal(value.to_string())
    }
}