| 105 | } |
| 106 | |
| 107 | void on_connection_open(proton::connection &c) override { |
| 108 | ASSERT(listen_handler.on_open_); |
| 109 | ASSERT(!listen_handler.on_close_); |
| 110 | ASSERT(listen_handler.on_error_.empty()); |
| 111 | // First call is the incoming server-side of the connection, that we are interested in. |
| 112 | // Second call is for the response to the client, ignore that. |
| 113 | if (!closing) { |
| 114 | peer_vhost = c.virtual_host(); |
| 115 | peer_container_id = c.container_id(); |
| 116 | peer_offered_capabilities = c.offered_capabilities(); |
| 117 | peer_desired_capabilities = c.desired_capabilities(); |
| 118 | peer_properties = c.properties(); |
| 119 | c.close(); |
| 120 | } |
| 121 | closing = true; |
| 122 | } |
| 123 | |
| 124 | void on_connection_close(proton::connection &) override { |
| 125 | if (!done) listener.stop(); |
nothing calls this directly
no test coverage detected