jessequ
/
qamqp
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update qamqpqueue.cpp

This commit is contained in:
Ernesto De Stefano 2016-02-03 22:59:42 +01:00
parent f6777e66df
commit b1cd8e48c3
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/qamqpqueue.cpp
View File

@ -18,7 +18,8 @@ QAmqpQueuePrivate::QAmqpQueuePrivate(QAmqpQueue *q)
declared(false), declared(false),
recievingMessage(false), recievingMessage(false),
consuming(false), consuming(false),
consumeRequested(false) consumeRequested(false),
arguments(QAmqpTable())
{ {
} }
@ -264,7 +265,7 @@ void QAmqpQueuePrivate::declare()
out << qint16(0); //reserved 1 out << qint16(0); //reserved 1
QAmqpFrame::writeAmqpField(out, QAmqpMetaType::ShortString, name); QAmqpFrame::writeAmqpField(out, QAmqpMetaType::ShortString, name);
out << qint8(options); out << qint8(options);
QAmqpFrame::writeAmqpField(out, QAmqpMetaType::Hash, QAmqpTable()); QAmqpFrame::writeAmqpField(out, QAmqpMetaType::Hash, arguments);
frame.setArguments(arguments); frame.setArguments(arguments);
sendFrame(frame); sendFrame(frame);
@ -328,10 +329,11 @@ int QAmqpQueue::options() const
return d->options; return d->options;
} }
void QAmqpQueue::declare(int options) void QAmqpQueue::declare(int options, const QAmqpTable arguments)
{ {
Q_D(QAmqpQueue); Q_D(QAmqpQueue);
d->options = options; d->options = options;
d->arguments = arguments;
if (!d->opened) { if (!d->opened) {
d->delayedDeclare = true; d->delayedDeclare = true;