Throw NJS-005 for queue.deqMany(0)

Author: cjbj

src/njsAqQueue.c

@@ -396,6 +396,8 @@ static bool njsAqQueue_deqManyProcessArgs(njsBaton *baton,
 {
     if (!njsUtils_getUnsignedIntArg(env, args, 0, &baton->numMsgProps))
         return false;
+    if (baton->numMsgProps == 0)
+        return njsUtils_throwError(env, errInvalidParameterValue, 1);
 
     return true;
 }

test/aq3.js

@@ -161,11 +161,17 @@ describe('219. aq3.js', function() {
     }
   }); // 219.4
 
-  it.skip('219.5 Negative - Set "maxMessages" argument to be 0', async () => {
+  it('219.5 Negative - Set "maxMessages" argument to be 0', async () => {
     try {
       const queue = await conn.getQueue(rawQueueName);
-      const messages = await queue.deqMany(0);
 
+      testsUtil.assertThrowsAsync(
+        async () => {
+          const messages = await queue.deqMany(0);
+          should.not.exist(messages);
+        },
+        /NJS-005/
+      );
     } catch (err) {
       should.not.exist(err);
     }
@@ -271,4 +277,4 @@ describe('219. aq3.js', function() {
       should.not.exist(err);
     }
   }); // 219.9
-});
+});