Add Begin frame to Session

Author: fafhrd91

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [5.3.0] - 2026-01-xx
+
+* Add `Begin` frame to `Session`
+
 ## [5.2.1] - 2026-01-16
 
 * Fix link credit handling

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-amqp"
-version = "5.2.1"
+version = "5.3.0"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "AMQP 1.0 Client/Server framework"
 documentation = "https://docs.rs/ntex-amqp"
@@ -27,7 +27,7 @@ frame-trace = []
 [dependencies]
 ntex-amqp-codec = "2.0.0"
 
-ntex-bytes = "1.2"
+ntex-bytes = "1.4"
 ntex-router = "1"
 ntex-rt = "3.4"
 ntex-io = "3.3"

src/connection.rs

@@ -262,9 +262,7 @@ impl ConnectionInner {
             false,
             ConnectionRef(cell.clone()),
             remote_channel_id,
-            begin.next_outgoing_id(),
-            begin.incoming_window(),
-            begin.outgoing_window(),
+            begin,
         ));
         entry.insert(SessionState::Established(session));
         self.sessions_map.insert(remote_channel_id, local_token);
@@ -312,9 +310,7 @@ impl ConnectionInner {
                         true,
                         ConnectionRef(cell.clone()),
                         remote_channel_id,
-                        begin.next_outgoing_id(),
-                        begin.incoming_window(),
-                        begin.outgoing_window(),
+                        begin,
                     ));
                     self.sessions_map.insert(remote_channel_id, local_token);
 

src/session.rs

@@ -64,6 +64,12 @@ impl Session {
         Session { inner }
     }
 
+    #[inline]
+    /// Get begin frame reference
+    pub fn frame(&self) -> &Begin {
+        &self.inner.get_ref().begin
+    }
+
     #[inline]
     /// Get io tag for current connection
     pub fn tag(&self) -> &'static str {
@@ -282,17 +288,12 @@ impl SessionInner {
         local: bool,
         sink: ConnectionRef,
         remote_channel_id: u16,
-        next_incoming_id: DeliveryNumber,
-        remote_incoming_window: u32,
-        remote_outgoing_window: u32,
+        begin: Begin,
     ) -> SessionInner {
         SessionInner {
-            id,
-            sink,
-            next_incoming_id,
-            remote_channel_id,
-            remote_incoming_window,
-            remote_outgoing_window,
+            next_incoming_id: begin.next_incoming_id(),
+            remote_incoming_window: begin.remote_incoming_window(),
+            remote_outgoing_window: begin.remote_outgoing_window(),
             flags: if local { Flags::LOCAL } else { Flags::empty() },
             next_outgoing_id: INITIAL_NEXT_OUTGOING_ID,
             unsettled_snd_deliveries: HashMap::default(),
@@ -305,6 +306,10 @@ impl SessionInner {
             pool_notify: pool::new(),
             pool_credit: pool::new(),
             closed: condition::Condition::new(),
+            id,
+            sink,
+            begin,
+            remote_channel_id,
         }
     }