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

Fix queue declaration arguments

This commit is contained in:
Thomas Vincent-Sweet 2016-06-22 11:16:17 +01:00
parent d3180c6545
commit fd7537c3f3
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/qamqpqueue.cpp
View File

@ -263,8 +263,8 @@ void QAmqpQueuePrivate::declare()
QAmqpMethodFrame frame(QAmqpFrame::Queue, QAmqpQueuePrivate::miDeclare); QAmqpMethodFrame frame(QAmqpFrame::Queue, QAmqpQueuePrivate::miDeclare);
frame.setChannel(channelNumber); frame.setChannel(channelNumber);
QByteArray arguments; QByteArray args;
QDataStream out(&arguments, QIODevice::WriteOnly); QDataStream out(&args, QIODevice::WriteOnly);
out << qint16(0); //reserved 1 out << qint16(0); //reserved 1
QAmqpFrame::writeAmqpField(out, QAmqpMetaType::ShortString, name); QAmqpFrame::writeAmqpField(out, QAmqpMetaType::ShortString, name);
@ -276,7 +276,7 @@ void QAmqpQueuePrivate::declare()
options & QAmqpQueue::Exclusive, options & QAmqpQueue::AutoDelete, options & QAmqpQueue::Exclusive, options & QAmqpQueue::AutoDelete,
options & QAmqpQueue::NoWait); options & QAmqpQueue::NoWait);
frame.setArguments(arguments); frame.setArguments(args);
sendFrame(frame); sendFrame(frame);
if (delayedDeclare) if (delayedDeclare)