mbroadst / qamqp

AMQP 0.9.1 implementation for Qt
Other
151 stars 127 forks source link

Message rejecting doesn't work #67

Closed IgorSysoev73 closed 7 years ago

IgorSysoev73 commented 7 years ago

Hi, I have a problem with message rejecting. The following method void QAmqpQueue::reject(const QAmqpMessage &message, bool requeue) doesn't work due to calling inside it wrong method. Current source code is:

void QAmqpQueue::reject(const QAmqpMessage &message, bool requeue)
{
    ack(message.deliveryTag(), requeue);
}

Have to be:

void QAmqpQueue::reject(const QAmqpMessage &message, bool requeue)
{
    reject(message.deliveryTag(), requeue);
}

Method void QAmqpQueue::reject(qlonglong deliveryTag, bool requeue) nevertheless works fine.

Thanks, Igor

mbroadst commented 7 years ago

@IgorSysoyev thanks for pointing this out, contributions are most welcome!

IgorSysoev73 commented 7 years ago

Fixed.