Skip to content

Commit 5b6f2b4

Browse files
author
Petr Matousek
committed
fixup
1 parent 9b5a967 commit 5b6f2b4

File tree

2 files changed

+9
-10
lines changed

2 files changed

+9
-10
lines changed

src/api/qpid-proton/reactor/handler/TxSenderHandler.cpp

+8-9
Original file line numberDiff line numberDiff line change
@@ -260,14 +260,13 @@ void TxSenderHandler::send()
260260

261261
// reactor methods
262262

263-
// TODO I guess not needed
264-
// void TxSenderHandler::on_sendable(sender &s)
265-
// {
266-
// logger(trace) << "[on_sendable] transaction: " << &tx;
267-
// if (ready) {
268-
// send();
269-
// }
270-
// }
263+
void TxSenderHandler::on_sendable(sender &s)
264+
{
265+
logger(trace) << "[on_sendable] transaction: " << &tx;
266+
if (ready) {
267+
send();
268+
}
269+
}
271270

272271

273272
void TxSenderHandler::on_tracker_accept(tracker &t)
@@ -277,7 +276,7 @@ void TxSenderHandler::on_tracker_accept(tracker &t)
277276

278277
void TxSenderHandler::on_tracker_reject(tracker &t)
279278
{
280-
std::cerr << "[on_tracker_reject] Delivery rejected" << std::endl;
279+
logger(trace) << "[on_tracker_reject] Delivery rejected";
281280
exit(1);
282281
}
283282

src/api/qpid-proton/reactor/handler/TxSenderHandler.h

+1-1
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ class TxSenderHandler : public CommonHandler, transaction_handler {
165165
// common reactor methods
166166
void on_container_start(container &c);
167167
void on_session_open(session &s);
168-
// void on_sendable(sender &s);
168+
void on_sendable(sender &s);
169169
void on_tracker_accept(tracker &t);
170170
void on_tracker_reject(tracker &t);
171171
void on_transport_error(transport &t);

0 commit comments

Comments
 (0)