Set transfer handle (#44)

ntex-rs · Mar 17, 2024 · a8c676a · a8c676a
1 parent 59ccafc
commit a8c676a
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 2 deletions.
diff --git a/CHANGES.md b/CHANGES.md
@@ -1,5 +1,9 @@
 # Changes
 
+## [2.1.2] - 2024-03-17
+
+* Set transfer handle
+
 ## [2.1.1] - 2024-03-12
 
 * Fix default flow's next-incoming-id

diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-amqp"
-version = "2.1.1"
+version = "2.1.2"
 authors = ["ntex contributors <[email protected]>"]
 description = "AMQP 1.0 Client/Server framework"
 documentation = "https://docs.rs/ntex-amqp"

diff --git a/src/session.rs b/src/session.rs
@@ -818,7 +818,10 @@ impl SessionInner {
                     if let Some(link) = self.links.get_mut(idx) {
                         match link {
                             Either::Left(_) => {
-                                log::error!("{}: Got trasfer from sender link", self.tag());
+                                log::error!(
+                                    "{}: Got unexpected trasfer from sender link",
+                                    self.tag()
+                                );
                                 Err(AmqpProtocolError::Unexpected(Frame::Transfer(transfer)))
                             }
                             Either::Right(link) => match link {
@@ -1247,6 +1250,7 @@ impl SessionInner {
             let chunk = body.split_to(std::cmp::min(max_frame_size, body.len()));
 
             let mut transfer = Transfer(Default::default());
+            transfer.0.handle = link_handle;
             transfer.0.body = Some(TransferBody::Data(chunk));
             transfer.0.more = true;
             transfer.0.settled = Some(settled);
@@ -1288,13 +1292,15 @@ impl SessionInner {
                 log::trace!("{}: Sending chunk tranfer for {:?}", self.tag(), tag);
 
                 let mut transfer = Transfer(Default::default());
+                transfer.0.handle = link_handle;
                 transfer.0.body = Some(TransferBody::Data(chunk));
                 transfer.0.more = true;
                 transfer.0.batchable = true;
                 self.post_frame(Frame::Transfer(transfer));
             }
         } else {
             let mut transfer = Transfer(Default::default());
+            transfer.0.handle = link_handle;
             transfer.0.body = Some(body);
             transfer.0.settled = Some(settled);
             transfer.0.state = tr_settled;