Fix handling of next_incoming_id

amqp · Sep 19, 2024 · 700cf8d · 700cf8d
1 parent 8fa5eb5
commit 700cf8d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/session.js b/lib/session.js
@@ -409,11 +409,13 @@ Incoming.prototype.process = function (session) {
 };
 
 Incoming.prototype.on_begin = function (fields) {
+    this.next_transfer_id = fields.next_outgoing_id;
     this.remote_window = fields.outgoing_window;
     this.remote_next_transfer_id = fields.next_outgoing_id;
 };
 
 Incoming.prototype.on_flow = function (fields) {
+    this.next_transfer_id = fields.next_outgoing_id;
     this.remote_next_transfer_id = fields.next_outgoing_id;
     this.remote_window = fields.outgoing_window;
 };