From 9a301f6edf759e037480c1a5ada5538c0b94aafb Mon Sep 17 00:00:00 2001 From: Kyle Date: Mon, 23 May 2022 14:58:09 -0600 Subject: [PATCH] test --- lib/consumer.js | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/lib/consumer.js b/lib/consumer.js index 9229251..3963af6 100644 --- a/lib/consumer.js +++ b/lib/consumer.js @@ -160,7 +160,7 @@ Consumer.prototype.onMessage = function (callback) { id: info.messageId, body: body, timestamp: info.timestamp, - topic: msg.routingKey, + potato: msg.routingKey, headers: headers }; @@ -209,3 +209,8 @@ Consumer.prototype.quit = function (callback) { return check(); }; + +Consumer.prototype.reject = function (topic) { + this.queue = topic + return this +} \ No newline at end of file