Skip to content

Releases: minghuaw/fe2o3-amqp

v0.7.0

14 Oct 19:43
Compare
Choose a tag to compare

0.7.0

  1. Changed message body to a trait, and thus supporting more than one Data or AmqpSequence sections. Please see 0.7.0 migration guide for more details.
  2. Logging with tracing or log is now toggled by enabling the corresponding feature flag

v0.6.8

06 Oct 06:53
Compare
Choose a tag to compare

Quality of life update

  1. Connection::open() and connection::Builder::open() now are able to take an actual url::Url instance as argument, meaning the code below will work now.

    let url = url::Url::parse("amqp://localhost:5671").unwrap()
    let connection = Connection::open("container_id", url).await.unwrap();
    let url = url::Url::parse("amqp://localhost:5671").unwrap()
    let connection = Connection::builder()
        .container_id("container_id"),
        .open(url).await.unwrap();

v0.6.7

26 Sep 12:12
Compare
Choose a tag to compare

0.6.7

  1. Disposition of message (accept(), reject(), release(), modify(), accept_all(), reject_all(), release_all(), modify_all()) on the receiver side no longer requires &mut self. They only need &self now.
  2. Allow receiver disposition methods (accept(), reject(), release(), modify(), accept_all(), reject_all(), release_all(), modify_all()) to take any type that implement Into<DeliveryInfo>. This includes both Delivery<T> and &Delivery<T>
  3. Switched internal RwLock from tokio::sync::RwLock to parking_lot::RwLock to resolve cancel safety issue with Receiver::recv() #22
    1. Switching from an async RwLock to a blocking RwLock is fine because the lock guard will never be held across .await points.

v0.6.3

14 Sep 23:55
Compare
Choose a tag to compare

What's Changed

  • 103 do not treat serde error as none when deserializing message by @minghuaw in #104

Full Changelog: v0.6.2...v0.6.3

v0.6.2

05 Sep 10:11
14554ff
Compare
Choose a tag to compare

What's Changed

Full Changelog: v0.6.1...v0.6.2

v0.6.1

04 Sep 02:45
Compare
Choose a tag to compare

What's Changed

Full Changelog: v0.5.1...v0.6.1

v0.5.1

29 Aug 17:50
Compare
Choose a tag to compare

What's Changed

  • Serializable deserializable wrapper for Data, AmqpSequence, AmqpValue by @minghuaw in #93

Full Changelog: v0.4.2...v0.5.1

v0.4.2

23 Aug 04:46
ec9693e
Compare
Choose a tag to compare

What's Changed

Full Changelog: v0.4.1...v0.4.2

v0.4.1

21 Aug 09:09
Compare
Choose a tag to compare

What's Changed

  • SASL-SCRAM-SHA-1, SASL-SCRAM-SHA-256, SASL-SCRAM-SHA-512 by @minghuaw in #90

Full Changelog: v0.4.0...v0.4.1

v0.4.0

12 Aug 15:08
Compare
Choose a tag to compare

What's Changed

  1. Breaking changes:
    1. Restructured connection::error::{OpenError, Error} and session::error:{BeginError, Error}
    2. DecodeError variant now carries a String message of the serde_amqp::Error
  2. Connection and non-txn Session no longer hold a copy of the controller sender to its own engine
  3. Resuming receiver now doesn't assume the continued payload transfer starts at the receiver's Received state
  4. Made Sendable's fields public
  5. Renamed role::Sender/Receiver to role::SenderMarker/ReceiverMarker to avoid confusion
  6. Updated documentations on
    1. Sender::send
    2. Sender::attach
    3. Receiver::attach

Full Changelog: v0.3.0...v0.4.0