| 59 | } |
| 60 | |
| 61 | void on_sendable(proton::sender &sender) override { |
| 62 | while (sender.credit() && sent < total) { |
| 63 | proton::message msg; |
| 64 | std::map<std::string, int> m; |
| 65 | m["sequence"] = sent + 1; |
| 66 | |
| 67 | msg.id(sent + 1); |
| 68 | msg.body(m); |
| 69 | |
| 70 | sender.send(msg); |
| 71 | sent++; |
| 72 | } |
| 73 | } |
| 74 | |
| 75 | void on_tracker_accept(proton::tracker &t) override { |
| 76 | confirmed++; |