lib/bbk/amqp/message.rb in bbk-amqp-1.0.0.76397 vs lib/bbk/amqp/message.rb in bbk-amqp-1.0.0.79544
- old
+ new
@@ -40,10 +40,10 @@
def ack(*args, answer: nil, **kwargs)
consumer.ack(self, *args, answer: answer, **kwargs)
end
def nack(*args, error: nil, **kwargs)
- consumer.ack(self, *args, error: error, **kwargs)
+ consumer.nack(self, *args, error: error, **kwargs)
end
end
end
end