fix(multi-transfer): fix issue with sending multi transfer frames

noodlefrenzy · Feb 16, 2016 · 6376e9d · 6376e9d
1 parent 26e6939
commit 6376e9d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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;
 };