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 2008/05/13 20:46:00 UTC
svn commit: r655968 - in /incubator/qpid/trunk/qpid/cpp/src/tests:
consume.cpp publish.cpp
Author: gsim
Date: Tue May 13 11:46:00 2008
New Revision: 655968
URL: http://svn.apache.org/viewvc?rev=655968&view=rev
Log:
Minor change to tests to use correlation id rather than body for identifying messages.
Modified:
incubator/qpid/trunk/qpid/cpp/src/tests/consume.cpp
incubator/qpid/trunk/qpid/cpp/src/tests/publish.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/tests/consume.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/consume.cpp?rev=655968&r1=655967&r2=655968&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/consume.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/consume.cpp Tue May 13 11:46:00 2008
@@ -77,7 +77,7 @@
Message msg;
for (size_t i = 0; i < opts.count; ++i) {
msg=lq.pop();
- std::cout << "Received: " << msg.getData().substr(0, 10) << "..." << std::endl;
+ std::cout << "Received: " << msg.getMessageProperties().getCorrelationId() << std::endl;
}
if (opts.ack != 0)
subs.getAckPolicy().ackOutstanding(session); // Cumulative ack for final batch.
Modified: incubator/qpid/trunk/qpid/cpp/src/tests/publish.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/publish.cpp?rev=655968&r1=655967&r2=655968&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/publish.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/publish.cpp Tue May 13 11:46:00 2008
@@ -69,6 +69,13 @@
session = connection.newSession(ASYNC);
}
+ std::string id(uint i)
+ {
+ std::stringstream s;
+ s << "msg" << i;
+ return s.str();
+ }
+
void publish()
{
Message msg(string(opts.size, 'X'), opts.routingKey);
@@ -76,8 +83,7 @@
msg.getDeliveryProperties().setDeliveryMode(framing::PERSISTENT);
for (uint i = 0; i < opts.count; i++) {
- const_cast<std::string&>(msg.getData()).replace(0, sizeof(uint32_t),
- reinterpret_cast<const char*>(&i), sizeof(uint32_t));
+ msg.getMessageProperties().setCorrelationId(id(i + 1));
session.messageTransfer(arg::destination=opts.destination,
arg::content=msg,
arg::acceptMode=1);