From b1cd8e48c3380c3324956d646017cca11ac3ab3a Mon Sep 17 00:00:00 2001 From: Ernesto De Stefano Date: Wed, 3 Feb 2016 22:59:42 +0100 Subject: [PATCH] Update qamqpqueue.cpp --- src/qamqpqueue.cpp | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/qamqpqueue.cpp b/src/qamqpqueue.cpp index 5a398c7..4473fe7 100644 --- a/src/qamqpqueue.cpp +++ b/src/qamqpqueue.cpp @@ -18,7 +18,8 @@ QAmqpQueuePrivate::QAmqpQueuePrivate(QAmqpQueue *q) declared(false), recievingMessage(false), consuming(false), - consumeRequested(false) + consumeRequested(false), + arguments(QAmqpTable()) { } @@ -264,7 +265,7 @@ void QAmqpQueuePrivate::declare() out << qint16(0); //reserved 1 QAmqpFrame::writeAmqpField(out, QAmqpMetaType::ShortString, name); out << qint8(options); - QAmqpFrame::writeAmqpField(out, QAmqpMetaType::Hash, QAmqpTable()); + QAmqpFrame::writeAmqpField(out, QAmqpMetaType::Hash, arguments); frame.setArguments(arguments); sendFrame(frame); @@ -328,10 +329,11 @@ int QAmqpQueue::options() const return d->options; } -void QAmqpQueue::declare(int options) +void QAmqpQueue::declare(int options, const QAmqpTable arguments) { Q_D(QAmqpQueue); d->options = options; + d->arguments = arguments; if (!d->opened) { d->delayedDeclare = true;