On release bahavior (#22)

* On release bahavior

Author: kornys

lib/coreClient.js

@@ -156,8 +156,10 @@ class CoreClient {
      * @param {object} context - event context
      */
     onReleased(context) {
-        context.connection.close();
-        throw new ErrorHandler('Message released');
+        if(this.options.releaseAction === 'fail') {
+            context.connection.close();
+            throw new ErrorHandler('Message released');
+        }
     }
 
     /**

lib/optionsParser.js

@@ -489,6 +489,7 @@ class SenderOptions extends SenderReceiverOptions {
         this.contentType;
         this.capacity;
         this.msgContentFromFile;
+        this.releaseAction;
     }
 
     /**
@@ -522,6 +523,7 @@ class SenderOptions extends SenderReceiverOptions {
                 'content-type':             { describe: 'specify how the msg content will be treated/casted'},
                 'capacity':                 { default: 0, describe: 'set sender capacity', type: 'uint'},
                 'anonymous':                { default: false, describe: 'send message by connection level anonymous sender', type: 'boolean'},
+                'on-release':               { default: 'fail', describe: 'behavior when message is released', type: 'string', choices: ['fail', 'retry', 'ignore']},
             });
         const args = this.parse(argsProcessor, listArgs);
 
@@ -543,6 +545,7 @@ class SenderOptions extends SenderReceiverOptions {
         this.msgContentType = args['msg-content-type'];
         this.msgContent = args['msg-content'];
         this.anonymous = args['anonymous'];
+        this.releaseAction = args['on-release'];
 
         if(args['msg-content-from-file']) {
             this.msgContentFromFile = Utils.readContentFromFile(args['msg-content-from-file']);

lib/senderClient.js

@@ -214,6 +214,9 @@ class Sender extends CoreClient {
         //release message
         this.container.on('released', function (context) {
             self.onReleased(context);
+            if (self.options.releaseAction === 'retry') {
+                context.sender.send(context.delivery);
+            }
         });
 
         //on protocol error

package.json

@@ -1,6 +1,6 @@
 {
   "name": "cli-rhea",
-  "version": "2.2.1",
+  "version": "2.2.2",
   "description": "Client interface built on amqp/rhea lib",
   "scripts": {
     "test": "mocha test/*Test.js",