summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2014-04-16 16:52:29 +0000
committerGordon Sim <gsim@apache.org>2014-04-16 16:52:29 +0000
commitff3227b0d6df2fd9f29c00d4ce0376c58e8a1e89 (patch)
treeb322df87480ef6f54f2cbfcc8303f96b011d37d7
parentb31213cae0570107926cbdecee05cdd939278e36 (diff)
downloadqpid-python-ff3227b0d6df2fd9f29c00d4ce0376c58e8a1e89.tar.gz
NO-JIRA: make new output introduced in r1587304 optional, as it breaks several tests
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1587976 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--cpp/src/tests/qpid-receive.cpp14
1 files changed, 9 insertions, 5 deletions
diff --git a/cpp/src/tests/qpid-receive.cpp b/cpp/src/tests/qpid-receive.cpp
index ed0bca11c1..19731da328 100644
--- a/cpp/src/tests/qpid-receive.cpp
+++ b/cpp/src/tests/qpid-receive.cpp
@@ -60,6 +60,7 @@ struct Options : public qpid::Options
uint tx;
uint rollbackFrequency;
bool printContent;
+ bool printContentObjectType;
bool printHeaders;
bool failoverUpdates;
qpid::log::Options log;
@@ -86,6 +87,7 @@ struct Options : public qpid::Options
tx(0),
rollbackFrequency(0),
printContent(true),
+ printContentObjectType(false),
printHeaders(false),
failoverUpdates(false),
log(argv0),
@@ -110,6 +112,7 @@ struct Options : public qpid::Options
("tx", qpid::optValue(tx, "N"), "batch size for transactions (0 implies transaction are not used)")
("rollback-frequency", qpid::optValue(rollbackFrequency, "N"), "rollback frequency (0 implies no transaction will be rolledback)")
("print-content", qpid::optValue(printContent, "yes|no"), "print out message content")
+ ("print-content-object-type", qpid::optValue(printContentObjectType, "yes|no"), "print a description of the content's object type if relevant")
("print-headers", qpid::optValue(printHeaders, "yes|no"), "print out message headers")
("failover-updates", qpid::optValue(failoverUpdates), "Listen for membership updates distributed via amq.failover")
("report-total", qpid::optValue(reportTotal), "Report total throughput and latency statistics")
@@ -237,11 +240,12 @@ int main(int argc, char ** argv)
}
if (opts.printContent) {
if (!msg.getContentObject().isVoid()) {
- std::cout << "[Object: " << getTypeName(msg.getContentObject().getType()) << "]" << std::endl
- << msg.getContentObject() << std::endl;
- }
- else {
- std::cout << msg.getContent() << std::endl;
+ if (opts.printContentObjectType) {
+ std::cout << "[Object: " << getTypeName(msg.getContentObject().getType()) << "]" << std::endl;
+ }
+ std::cout << msg.getContentObject() << std::endl;
+ } else {
+ std::cout << msg.getContent() << std::endl;
}
}
if (opts.messages && count >= opts.messages) done = true;