search

minghuaw / fe2o3-amqp

A rust implementation of the AMQP1.0 protocol based on serde and tokio.
MIT License
58 stars 7 forks source link

0.10 dev #233

Closed minghuaw closed 6 months ago

minghuaw commented 6 months ago

fe2o3-amqp

  1. Changed RecvError::MessageDecodeError to RecvError::MessageDecode(MessageDecodeError).
  2. Added MessageDecodeError which carries the source serde_amqp::Error when deserializing the message body fails and the delivery info that can be used to dispose the message.

fe2o3-amqp-cbs

  1. Replace GAT with async fn in trait for AsyncCbsTokenProvider trait