diff options
| author | Gordon Sim <gsim@apache.org> | 2011-02-25 16:14:32 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2011-02-25 16:14:32 +0000 |
| commit | b89260805d612679ae6ef03d491873d671d53749 (patch) | |
| tree | 68f245162932282e3b15e22547d50aa49859d5b2 /cpp/src/qpid/client | |
| parent | b5027a43f535995f37472672583dbb87c0a02aff (diff) | |
| download | qpid-python-b89260805d612679ae6ef03d491873d671d53749.tar.gz | |
QPID-2999: set redelivered on replay
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1074611 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client')
| -rw-r--r-- | cpp/src/qpid/client/amqp0_10/SenderImpl.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp b/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp index e1b75ec0cf..f2f0f1a9e5 100644 --- a/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp +++ b/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp @@ -135,6 +135,7 @@ void SenderImpl::sendUnreliable(const qpid::messaging::Message& m) void SenderImpl::replay(const sys::Mutex::ScopedLock&) { for (OutgoingMessages::iterator i = outgoing.begin(); i != outgoing.end(); ++i) { + i->message.setRedelivered(true); sink->send(session, name, *i); } } @@ -147,7 +148,7 @@ uint32_t SenderImpl::checkPendingSends(bool flush) { uint32_t SenderImpl::checkPendingSends(bool flush, const sys::Mutex::ScopedLock&) { if (flush) { - session.flush(); + session.flush(); flushed = true; } else { flushed = false; |