From fe3c26f3b056cbfedc1f9d4cfd1bd6ae76ec3904 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 12 Mar 2013 14:35:11 +0000 Subject: QPID-4576: commit "ready" message if session is transactional; patch from Pavel Moravec git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1455549 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/qpid-receive.cpp | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'qpid/cpp/src') diff --git a/qpid/cpp/src/tests/qpid-receive.cpp b/qpid/cpp/src/tests/qpid-receive.cpp index e623d052e8..9cbf7c4808 100644 --- a/qpid/cpp/src/tests/qpid-receive.cpp +++ b/qpid/cpp/src/tests/qpid-receive.cpp @@ -200,8 +200,11 @@ int main(int argc, char ** argv) Duration timeout = opts.getTimeout(); bool done = false; Reporter reporter(std::cout, opts.reportEvery, opts.reportHeader); - if (!opts.readyAddress.empty()) + if (!opts.readyAddress.empty()) { session.createSender(opts.readyAddress).send(msg); + if (opts.tx) + session.commit(); + } // For receive rate calculation qpid::sys::AbsTime start = qpid::sys::now(); int64_t interval = 0; -- cgit v1.2.1