jessequ
/
AMQP-CPP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Simplify message counter logic

This commit is contained in:
Marcin Gibula 2017-06-08 23:41:55 +02:00
parent 061c462ee0
commit 3ab9eed268
4 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
include/channel.h
View File

@ -137,8 +137,8 @@ public:
/** /**
* Return number of messages sent. * Return number of messages sent.
* *
* This functions returns number of messages sent. It's incremented only * This functions returns number of messages sent. It's reset to zero when channel is
* when channel is in confirm mode. * put into confirm mode.
*/ */
uint64_t messageCounter() const uint64_t messageCounter() const
{ {

6
include/channelimpl.h
View File

@ -764,11 +764,11 @@ public:
void complete(); void complete();
/** /**
* Start message counter * Reset message counter
*/ */
void startMessageCounter() void resetMessageCounter()
{ {
_messageCounter = 1; _messageCounter = 0;
} }
/** /**

3
src/channelimpl.cpp
View File

@ -505,8 +505,7 @@ bool ChannelImpl::publish(const std::string &exchange, const std::string &routin
bytesleft -= chunksize; bytesleft -= chunksize;
} }
// increment message counter if we're in confirm mode // increment message counter
if (_messageCounter)
_messageCounter++; _messageCounter++;
// done // done

4
src/confirmselectokframe.h
View File

@ -74,8 +74,8 @@ public:
// channel does not exist // channel does not exist
if(!channel) return false; if(!channel) return false;
// start message counter // reset message counter
channel->startMessageCounter(); channel->resetMessageCounter();
// report that the channel is open // report that the channel is open
if (channel->reportSuccess()) channel->onSynchronized(); if (channel->reportSuccess()) channel->onSynchronized();