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 | e355240745fd2bc9da8ef5a0ee7926745507dab4 (patch) | |
| tree | e6f49dd860347852fab891d0310b72084fceb5b2 /cpp/src | |
| parent | 281d3195d40b186d4791af3764355ab30bf16921 (diff) | |
| download | qpid-python-e355240745fd2bc9da8ef5a0ee7926745507dab4.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/qpid@1455549 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/tests/qpid-receive.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/cpp/src/tests/qpid-receive.cpp b/cpp/src/tests/qpid-receive.cpp index e623d052e8..9cbf7c4808 100644 --- a/cpp/src/tests/qpid-receive.cpp +++ b/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; |