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