| 119 | } |
| 120 | |
| 121 | void on_message(proton::delivery & d, proton::message & m) override { |
| 122 | ++messages_; |
| 123 | proton::connection c = d.connection(); |
| 124 | if (messages_==expect_) close(c); |
| 125 | else d.accept(); |
| 126 | } |
| 127 | |
| 128 | void on_transport_error(proton::transport & ) override { |
| 129 | // If we get an error then (try to) stop the listener |
nothing calls this directly
no test coverage detected