MCPcopy Create free account
hub / github.com/apache/qpid-proton / on_connection_open

Method on_connection_open

cpp/src/reconnect_test.cpp:136–146  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

134
135class tester_base: public proton::messaging_handler {
136 void on_connection_open(proton::connection& c) override {
137 std::string want_url = "amqp://localhost:" + std::to_string(listening_port_);
138
139 if (!c.reconnected()) {
140 start_count++;
141 c.open_sender("messages");
142 }
143 ASSERT_EQUAL(c.url(), want_url);
144 ASSERT_EQUAL(bool(open_count), c.reconnected());
145 open_count++;
146 }
147
148 void on_connection_error(proton::connection& c) override {
149 connection_error_count++;

Callers

nothing calls this directly

Calls 4

reconnectedMethod · 0.80
to_stringFunction · 0.70
open_senderMethod · 0.45
urlMethod · 0.45

Tested by

no test coverage detected