We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 368c848 commit 4dbb900Copy full SHA for 4dbb900
src/api/qpid-proton/reactor/handler/TxReceiverHandler.cpp
@@ -138,11 +138,13 @@ void TxReceiverHandler::on_session_open(session &s) {
138
s.transaction_declare(*this);
139
} else {
140
logger(trace) << "[on_session_open] Transaction is declared: " << s.transaction_id();
141
+ if (count != 0 && (processed + batch_size > count)) {
142
+ batch_size = count % batch_size;
143
+ } else if (count == 0) {
144
+ batch_size = 1;
145
+ }
146
recv.add_credit(batch_size);
147
logger(debug) << "[on_session_open] Receiver credit: " << recv.credit();
- if (count != 0 && processed + batch_size > count) {
- batch_size = count % batch_size;
- }
148
}
149
150
0 commit comments