From 4a30dba26656815ccb2fbba91de8d90f50eeb288 Mon Sep 17 00:00:00 2001
From: Brad Jorgensen <Brad@debtpaypro.com>
Date: Mon, 2 Mar 2015 13:25:26 -0600
Subject: [PATCH] fixes qosBasic and rejectBasic

---
 src/amqp/AmqpClient.js | 7 +++++--
 src/amqp/AmqpEvent.js  | 2 ++
 2 files changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/amqp/AmqpClient.js b/src/amqp/AmqpClient.js
index 2df1dbc..eed2669 100644
--- a/src/amqp/AmqpClient.js
+++ b/src/amqp/AmqpClient.js
@@ -157,6 +157,7 @@ _prototype._init = function() {
                          "consumeOkBasicFrame",
                          "recoverOkBasicFrame",
                          "rejectOkBasicFrame",
+                         "qosOkBasicFrame",
 
 
                         // async message delivery:
@@ -742,9 +743,9 @@ var initChannel = function initChannel(channel, id, connection, cb) {
                          "deleteExchangeAction",
                          "purgeQueueAction",
                          "cancelBasicAction",
+                         "qosBasicAction",
 
                          "recoverBasicAction",
-                         "rejectBasicAction",
 
 
                          "selectTxAction",
@@ -756,7 +757,8 @@ var initChannel = function initChannel(channel, id, connection, cb) {
 
             // perform asychronous action and stay in the ready state
             {"inputs": ["publishBasicAction",
-                        "ackBasicAction"
+                        "ackBasicAction",
+                        "rejectBasicAction"
                         ], "targetState" : "channelReady"},
 
             // start getting a single message
@@ -806,6 +808,7 @@ var initChannel = function initChannel(channel, id, connection, cb) {
                          "cancelOkBasicFrame",
                          "recoverOkBasicFrame",
                          "rejectOkBasicFrame",
+                         "qosOkBasicFrame",
 
 
                          // transactions
diff --git a/src/amqp/AmqpEvent.js b/src/amqp/AmqpEvent.js
index 2608ae9..b3f661e 100644
--- a/src/amqp/AmqpEvent.js
+++ b/src/amqp/AmqpEvent.js
@@ -54,6 +54,8 @@
                 return "recover";
             case "rejectOkBasic":
                 return "reject";
+            case "qosOkBasic":
+                return "qos";
                 
             case "error":
                 return "error";