From 6376e9dcae3a22483b1aef043a477e2b10a01b5d Mon Sep 17 00:00:00 2001 From: Matt Broadstone Date: Mon, 15 Feb 2016 17:48:35 -0500 Subject: [PATCH] fix(multi-transfer): fix issue with sending multi transfer frames --- lib/receiver_link.js | 3 +-- lib/sender_link.js | 3 ++- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/receiver_link.js b/lib/receiver_link.js index d11b2ab..7c0de31 100644 --- a/lib/receiver_link.js +++ b/lib/receiver_link.js @@ -175,8 +175,7 @@ ReceiverLink.prototype._messageReceived = function(transferFrame) { } // optionally decode message based on policy - var payload = message.body; - message.body = this.policy.decoder ? this.policy.decoder(payload) : payload; + message.body = this.policy.decoder ? this.policy.decoder(message.body) : message.body; debug('received from (' + this.name + '): ' + message.body); this.emit(Link.MessageReceived, message); diff --git a/lib/sender_link.js b/lib/sender_link.js index f45d950..a8a7c30 100644 --- a/lib/sender_link.js +++ b/lib/sender_link.js @@ -172,14 +172,15 @@ SenderLink.prototype._sendMessage = function(message, options) { transferOptions.more = (i !== messageCount - 1) ? true : false; frame = new frames.TransferFrame(transferOptions); frame.payload = messageBuffer.slice(bufferIdx, bufferIdx + idealMessageSize); + this.session.connection.sendFrame(frame); bufferIdx += idealMessageSize; } } else { frame = new frames.TransferFrame(transferOptions); frame.payload = messageBuffer; + this.session.connection.sendFrame(frame); } - this.session.connection.sendFrame(frame); this.linkCredit--; return messageId; };