diff --git a/CHANGES.md b/CHANGES.md
index f85f3d7..8302468 100644
--- 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
index 7ed7ad3..626e6fa 100644
--- 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 <team@ntex.rs>"]
 description = "AMQP 1.0 Client/Server framework"
 documentation = "https://docs.rs/ntex-amqp"
diff --git a/src/session.rs b/src/session.rs
index 75179ed..fc40612 100644
--- 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,6 +1292,7 @@ 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;
@@ -1295,6 +1300,7 @@ impl SessionInner {
             }
         } 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;