Increase expected acks on buffered producer after producing

This commit is contained in:
Matias Fontanini
2017-08-24 15:04:54 -07:00
parent 86d4bc8037
commit d0c794b978

View File

@@ -186,8 +186,8 @@ void BufferedProducer<BufferType>::add_message(Builder builder) {
template <typename BufferType>
void BufferedProducer<BufferType>::produce(const MessageBuilder& builder) {
expected_acks_++;
produce_message(builder);
expected_acks_++;
}
template <typename BufferType>