From 301296262b9588d379e5a5667a6be1f59296df71 Mon Sep 17 00:00:00 2001 From: Matt Broadstone Date: Tue, 3 Nov 2015 21:43:54 -0500 Subject: [PATCH] test(send-multi-frame): add breaking test for multiple frame sends --- test/unit/client.test.js | 30 ++++++++++++++++++++++++++---- 1 file changed, 26 insertions(+), 4 deletions(-) diff --git a/test/unit/client.test.js b/test/unit/client.test.js index 17f26b6..e7b5311 100644 --- a/test/unit/client.test.js +++ b/test/unit/client.test.js @@ -181,13 +181,35 @@ describe('Client', function() { new CloseFrame(new AMQPError(AMQPError.ConnectionForced, 'test')) ]); + // build our expected buffer segments + var message = new M.Message({ body: 'asupercalifragilisticexpialidocious' }); + var codecBuffer = new Builder(); + Codec.encode(message, codecBuffer); + var messageBuffer = codecBuffer.get(); + + var expected = []; + expected.push(messageBuffer.slice(0, 10)); + expected.push(messageBuffer.slice(10, 20)); + expected.push(messageBuffer.slice(20, 30)); + expected.push(messageBuffer.slice(30, 40)); + test.server.setExpectedFrameSequence([ false, false, false, false, new TransferFrame({ - frameType: 0, channel: 1, handle: 0, deliveryId: 1, settled: false, deliveryTag: 1, - message: new M.Message({ body: 'supercalifragilisticexpialidocious' }), - messageFormat: 0, more: false, receiverSettleMode: null, - state: null, resume: false, aborted: false, batchable: false + channel: 1, handle: 0, deliveryId: 1, settled: false, deliveryTag: 1, + message: expected[0], more: true, + }), + new TransferFrame({ + channel: 1, handle: 0, deliveryId: 2, settled: false, deliveryTag: 1, + message: expected[1], more: true, + }), + new TransferFrame({ + channel: 1, handle: 0, deliveryId: 3, settled: false, deliveryTag: 1, + message: expected[2], more: true, + }), + new TransferFrame({ + channel: 1, handle: 0, deliveryId: 4, settled: false, deliveryTag: 1, + message: expected[3], more: false, }), false ]);