diff options
| author | Gordon Sim <gsim@apache.org> | 2013-03-12 14:35:11 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-03-12 14:35:11 +0000 |
| commit | fe3c26f3b056cbfedc1f9d4cfd1bd6ae76ec3904 (patch) | |
| tree | 1826f04217a7208eefb30c446d7b8a8b6041064d /qpid/cpp/src | |
| parent | b0bde87b083479062cdd32d7e3bb64907a211f34 (diff) | |
| download | qpid-python-fe3c26f3b056cbfedc1f9d4cfd1bd6ae76ec3904.tar.gz | |
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
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/tests/qpid-receive.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
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<ThroughputAndLatency> 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; |