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

Merge pull request #50 from TomVS/master 

Fix queue declaration arguments
This commit is contained in:
Matt Broadstone 2016-09-22 09:28:12 -04:00 committed by GitHub
parent d3180c6545 2270f0ba95
commit 6d73c4c578
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/qamqpexchange.cpp
View File

@ -321,7 +321,6 @@ void QAmqpExchange::publish(const QByteArray &message, const QString &routingKey
content.setProperty(QAmqpMessage::ContentType, mimeType); content.setProperty(QAmqpMessage::ContentType, mimeType);
content.setProperty(QAmqpMessage::ContentEncoding, "utf-8"); content.setProperty(QAmqpMessage::ContentEncoding, "utf-8");
content.setProperty(QAmqpMessage::Headers, headers); content.setProperty(QAmqpMessage::Headers, headers);
content.setProperty(QAmqpMessage::MessageId, "0");
QAmqpMessage::PropertyHash::ConstIterator it; QAmqpMessage::PropertyHash::ConstIterator it;
QAmqpMessage::PropertyHash::ConstIterator itEnd = properties.constEnd(); QAmqpMessage::PropertyHash::ConstIterator itEnd = properties.constEnd();

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)