Enum AmqpError 

#[non_exhaustive]
pub enum AmqpError {
    Connect(Box<dyn StdError + Send + Sync>),
    Session(Box<dyn StdError + Send + Sync>),
    Attach {
        address: String,
        source: Box<dyn StdError + Send + Sync>,
    },
    Publish {
        address: String,
        source: Box<dyn StdError + Send + Sync>,
    },
    PublishNotAccepted {
        address: String,
        outcome: String,
    },
    Receive {
        address: String,
        source: Box<dyn StdError + Send + Sync>,
    },
    UnsupportedBody {
        address: String,
    },
    RequestTimeout,
    NotConnected,
    InvalidAddress(String),
}

Errors returned by the AMQP 1.0 broker.

One enum for the whole crate, variants by source, per the RustStream broker conventions. The wrapped sources are boxed std errors so the public API does not leak fe2o3-amqp types.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Connect(Box<dyn StdError + Send + Sync>)

Opening the connection (TCP, TLS, SASL, or the AMQP handshake) failed.

Session(Box<dyn StdError + Send + Sync>)

Beginning a session on the live connection failed.

Attach

Attaching a link (sender or receiver) failed.

Fields

address: String

The address the link was attached to.

source: Box<dyn StdError + Send + Sync>

The client’s attach failure.

Publish

The transport failed while sending a message.

Fields

address: String

The address the message was published to.

source: Box<dyn StdError + Send + Sync>

The client’s send failure.

PublishNotAccepted

The peer settled an outgoing message with a non-accepted outcome (rejected, released, or modified), so the message is not on the broker.

Fields

address: String

The address the message was published to.

outcome: String

A description of the peer’s outcome, including the error condition when one was carried.

Receive

The transport failed while receiving a message.

Fields

address: String

The source address of the subscription.

source: Box<dyn StdError + Send + Sync>

The client’s receive failure.

UnsupportedBody

A delivery arrived whose body the crate cannot expose as bytes (an AMQP value section that is neither binary nor a string).

Fields

address: String

The source address of the subscription.

RequestTimeout

A request/reply round trip did not produce a reply within the caller’s timeout.

NotConnected

The handle is used before connect filled the shared connection, or after shutdown.

InvalidAddress(String)

A subscription descriptor is invalid.

Trait Implementations

impl Debug for AmqpError

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

Formats the value using the given formatter.

impl Display for AmqpError

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

Formats the value using the given formatter.

impl Error for AmqpError

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.