Enum BrokerError 

pub enum BrokerError {
    Connection(String),
    Serialization(String),
    QueueNotFound(String),
    MessageNotFound(Uuid),
    Timeout,
    Configuration(String),
    OperationFailed(String),
}

Broker errors

Examples

use celers_kombu::BrokerError;

let err = BrokerError::Connection("failed to connect".to_string());
assert!(err.is_connection());
assert!(err.is_retryable());
assert_eq!(err.category(), "connection");

let err = BrokerError::Timeout;
assert!(err.is_timeout());
assert!(err.is_retryable());

let err = BrokerError::QueueNotFound("celery".to_string());
assert!(err.is_queue_not_found());
assert!(!err.is_retryable());

Variants

Connection(String)

Serialization(String)

QueueNotFound(String)

MessageNotFound(Uuid)

Timeout

Configuration(String)

OperationFailed(String)

Implementations

impl BrokerError

pub fn is_connection(&self) -> bool

Check if the error is connection-related

pub fn is_serialization(&self) -> bool

Check if the error is serialization-related

pub fn is_queue_not_found(&self) -> bool

Check if the error is queue-not-found

pub fn is_message_not_found(&self) -> bool

Check if the error is message-not-found

pub fn is_timeout(&self) -> bool

Check if the error is a timeout

pub fn is_configuration(&self) -> bool

Check if the error is configuration-related

pub fn is_operation_failed(&self) -> bool

Check if the error is an operation failure

pub fn is_retryable(&self) -> bool

Check if this is a retryable error

Returns true for connection, timeout, and operation failures, which are typically transient. Returns false for serialization, configuration, and not-found errors.

pub fn category(&self) -> &'static str

Get the error category as a string

Trait Implementations

impl Debug for BrokerError

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Display for BrokerError

fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Error for BrokerError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.