summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2011-08-14 16:21:34 +0000
committerRobert Godfrey <rgodfrey@apache.org>2011-08-14 16:21:34 +0000
commitd84a3a50dbb794c4383de7e5eca730ca602771e7 (patch)
tree7c6177573a2eedc172de2cbd8354ce7b4ea1e8fe /qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
parent0aba202a7e2483f04fc77bbe4faa88bb86fe5b9b (diff)
parent47551f3aa2dd46b8daeeb9683a668464203ffa06 (diff)
downloadqpid-python-d84a3a50dbb794c4383de7e5eca730ca602771e7.tar.gz
Create sandbox from correct revision
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/rg-amqp-1-0-sandbox@1157557 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp')
-rw-r--r--qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp3
1 files changed, 1 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp b/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
index f2f0f1a9e5..e1b75ec0cf 100644
--- a/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
+++ b/qpid/cpp/src/qpid/client/amqp0_10/SenderImpl.cpp
@@ -135,7 +135,6 @@ 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);
}
}
@@ -148,7 +147,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;