You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2010/06/10 15:36:15 UTC
svn commit: r953321 - in /qpid/trunk/qpid/cpp/src:
qpid/client/amqp0_10/IncomingMessages.cpp tests/MessagingSessionTests.cpp
Author: gsim
Date: Thu Jun 10 13:36:15 2010
New Revision: 953321
URL: http://svn.apache.org/viewvc?rev=953321&view=rev
Log:
QPID-664: Correct the name of the subject string used for incoming messages.
Modified:
qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp
qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp?rev=953321&r1=953320&r2=953321&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp Thu Jun 10 13:36:15 2010
@@ -289,7 +289,7 @@ void IncomingMessages::MessageTransfer::
namespace {
//TODO: unify conversion to and from 0-10 message that is currently
//split between IncomingMessages and OutgoingMessage
-const std::string SUBJECT("subject");
+const std::string SUBJECT("qpid.subject");
}
void populateHeaders(qpid::messaging::Message& message,
Modified: qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp?rev=953321&r1=953320&r2=953321&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp (original)
+++ qpid/trunk/qpid/cpp/src/tests/MessagingSessionTests.cpp Thu Jun 10 13:36:15 2010
@@ -55,11 +55,13 @@ QPID_AUTO_TEST_CASE(testSimpleSendReceiv
QueueFixture fix;
Sender sender = fix.session.createSender(fix.queue);
Message out("test-message");
+ out.setSubject("test-subject");
sender.send(out);
Receiver receiver = fix.session.createReceiver(fix.queue);
Message in = receiver.fetch(Duration::SECOND * 5);
fix.session.acknowledge();
BOOST_CHECK_EQUAL(in.getContent(), out.getContent());
+ BOOST_CHECK_EQUAL(in.getSubject(), out.getSubject());
}
QPID_AUTO_TEST_CASE(testSyncSendReceive)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org