Enum PublishError 

#[non_exhaustive]
pub enum PublishError {
    Rpc(Arc<Error>),
    OrderingKeyPaused,
    Shutdown,
}

Represents an error that can occur when publishing a message.

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.

Rpc(Arc<Error>)

The underlying RPC failed.

The inner error is wrapped in an Arc because the same error may affect multiple publish() calls.

OrderingKeyPaused

Publishing is paused because a previous message with the same ordering key failed.

To prevent messages from being sent out of order, the Publisher paused messages for the ordering key.

To resume publishing, call Publisher::resume_publish.

Shutdown

The operation failed because the Publisher has been shut down.

Typically this can happen when the application is shutting down. Some background tasks in the client library may be terminated before they can send all the pending messages.

Trait Implementations

impl Debug for PublishError

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

Formats the value using the given formatter.

impl Display for PublishError

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

Formats the value using the given formatter.

impl Error for PublishError

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.