diff --git a/README.md b/README.md index 3929bbb..7c179bb 100644 --- a/README.md +++ b/README.md @@ -67,7 +67,7 @@ int main() { boost::asio::io_context ioc; using client_type = async_mqtt5::mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("", "", "") .brokers("", 1883) diff --git a/doc/qbk/01_intro.qbk b/doc/qbk/01_intro.qbk index 4cbceee..07ab59a 100644 --- a/doc/qbk/01_intro.qbk +++ b/doc/qbk/01_intro.qbk @@ -58,7 +58,7 @@ The following example illustrates a simple scenario of configuring a Client and boost::asio::io_context ioc; using client_type = async_mqtt5::mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("", "", "") .brokers("", 1883) diff --git a/example/callbacks.cpp b/example/callbacks.cpp index 28e9fc4..fbf9648 100644 --- a/example/callbacks.cpp +++ b/example/callbacks.cpp @@ -103,7 +103,7 @@ int main(int argc, char** argv) { asio::io_context ioc; // Make an instance of mqtt_client. Establish a TCP connection with the Broker. - client_type c(ioc.get_executor(), ""); + client_type c(ioc.get_executor()); c.credentials("test-client", "username", "password") .brokers("mqtt.broker", 1883) diff --git a/example/cpp20_coroutines.cpp b/example/cpp20_coroutines.cpp index 2e1e50a..fef3c19 100644 --- a/example/cpp20_coroutines.cpp +++ b/example/cpp20_coroutines.cpp @@ -161,7 +161,7 @@ int main(int argc, char** argv) { asio::io_context ioc; // Make an instance of mqtt_client. Establish a TCP connection with the Broker. - client_type c(ioc.get_executor(), ""); + client_type c(ioc.get_executor()); c.credentials("test-client", "username", "password") .brokers("mqtt.broker", 1883) diff --git a/example/futures.cpp b/example/futures.cpp index d4e86c7..dd681d2 100644 --- a/example/futures.cpp +++ b/example/futures.cpp @@ -92,7 +92,7 @@ int main(int argc, char** argv) { threads.reserve(thread_num - 1); // Make an instance of mqtt_client. Establish a TCP connection with the Broker. - client_type c(ioc.get_executor(), ""); + client_type c(ioc.get_executor()); c.credentials("test-client", "", "") .brokers("mqtt.broker", 1883) diff --git a/example/network_connection.cpp b/example/network_connection.cpp index 6a930cc..e5f91d1 100644 --- a/example/network_connection.cpp +++ b/example/network_connection.cpp @@ -12,7 +12,7 @@ void tcp_setup() { boost::asio::io_context ioc; // Use ``__TCP_SOCKET__`` as the underlying stream. - async_mqtt5::mqtt_client client(ioc, ""); + async_mqtt5::mqtt_client client(ioc); } //] @@ -77,7 +77,7 @@ void ssl_setup() { async_mqtt5::mqtt_client< boost::asio::ssl::stream, boost::asio::ssl::context - > client(ioc, "", std::move(context)); + > client(ioc, std::move(context)); } //] @@ -96,7 +96,7 @@ void websocket_tcp_setup() { // Use ``[beastreflink boost__beast__websocket__stream websocket::stream<__TCP_SOCKET__>]`` as the underlying stream. async_mqtt5::mqtt_client< boost::beast::websocket::stream - > client(ioc, ""); + > client(ioc); } //] @@ -167,7 +167,7 @@ void websocket_tls_setup() { async_mqtt5::mqtt_client< boost::beast::websocket::stream>, boost::asio::ssl::context - > client(ioc, "", std::move(context)); + > client(ioc, std::move(context)); } //] diff --git a/example/openssl_tls.cpp b/example/openssl_tls.cpp index 21d72f3..993e752 100644 --- a/example/openssl_tls.cpp +++ b/example/openssl_tls.cpp @@ -65,7 +65,7 @@ void publish_qos0_openssl_tls() { tls_context.set_verify_mode(asio::ssl::verify_peer); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.credentials("test-qos0-openssl-tls", "", "") .brokers("emqtt.mireo.local", 8883) @@ -98,7 +98,7 @@ void publish_qos1_openssl_tls() { tls_context.set_verify_mode(asio::ssl::verify_peer); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.credentials("test-qos1-openssl-tls", "", "") .brokers("emqtt.mireo.local", 8883) @@ -133,7 +133,7 @@ void publish_qos2_openssl_tls() { tls_context.set_verify_mode(asio::ssl::verify_peer); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.credentials("test-qos2-openssl-tls", "", "") .brokers("emqtt.mireo.local", 8883) @@ -168,7 +168,7 @@ void subscribe_and_receive_openssl_tls(int num_receive) { tls_context.set_verify_mode(asio::ssl::verify_peer); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.credentials("test-subscriber-openssl-tls", "", "") .brokers("emqtt.mireo.local", 8883) diff --git a/example/publisher.cpp b/example/publisher.cpp index a894e45..e0e4a93 100644 --- a/example/publisher.cpp +++ b/example/publisher.cpp @@ -16,7 +16,7 @@ namespace asio = boost::asio; asio::awaitable client_publisher(asio::io_context& ioc) { // Initialise the Client, establish connection to the Broker over TCP. - async_mqtt5::mqtt_client client(ioc, ""); + async_mqtt5::mqtt_client client(ioc); // Configure the Client. // It is mandatory to call brokers() and async_run() to configure the Brokers to connect to and start the Client. diff --git a/example/receiver.cpp b/example/receiver.cpp index e340bfa..938880f 100644 --- a/example/receiver.cpp +++ b/example/receiver.cpp @@ -16,7 +16,7 @@ namespace asio = boost::asio; asio::awaitable client_receiver(asio::io_context& ioc) { // Initialise the Client, establish connection to the Broker over TCP. - async_mqtt5::mqtt_client client(ioc, ""); + async_mqtt5::mqtt_client client(ioc); // Configure the Client. // It is mandatory to call brokers() and async_run() to configure the Brokers to connect to and start the Client. diff --git a/example/tcp.cpp b/example/tcp.cpp index 4917fb6..4844e61 100644 --- a/example/tcp.cpp +++ b/example/tcp.cpp @@ -15,7 +15,7 @@ void publish_qos0_tcp() { using stream_type = asio::ip::tcp::socket; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); connect_props props; props[prop::maximum_packet_size] = 1024; @@ -47,7 +47,7 @@ void publish_qos1_tcp() { using stream_type = asio::ip::tcp::socket; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("test-qos1-tcp", "", "") .brokers("emqtt.mireo.local", 1883) @@ -74,7 +74,7 @@ void publish_qos2_tcp() { using stream_type = asio::ip::tcp::socket; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("test-qos2-tcp", "", "") .brokers("emqtt.mireo.local", 1883) @@ -102,7 +102,7 @@ void subscribe_and_receive_tcp(int num_receive) { using stream_type = asio::ip::tcp::socket; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("test-subscriber-tcp", "", "") .brokers("emqtt.mireo.local", 1883) diff --git a/example/websocket_tcp.cpp b/example/websocket_tcp.cpp index a59a64c..8ee0e19 100644 --- a/example/websocket_tcp.cpp +++ b/example/websocket_tcp.cpp @@ -20,7 +20,7 @@ void publish_qos0_websocket_tcp() { >; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("test-qos0-websocket-tcp", "", "") .brokers("emqtt.mireo.local/mqtt", 8083) @@ -50,7 +50,7 @@ void publish_qos1_websocket_tcp() { >; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("test-qos1-websocket-tcp", "", "") .brokers("emqtt.mireo.local/mqtt", 8083) @@ -81,7 +81,7 @@ void publish_qos2_websocket_tcp() { >; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("test-qos2-websocket-tcp", "", "") .brokers("emqtt.mireo.local/mqtt", 8083) @@ -113,7 +113,7 @@ void subscribe_and_receive_websocket_tcp(int num_receive) { >; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.credentials("test-subscriber-websocket-tcp", "", "") .brokers("emqtt.mireo.local/mqtt", 8083) diff --git a/example/websocket_tls.cpp b/example/websocket_tls.cpp index bb648e5..2497225 100644 --- a/example/websocket_tls.cpp +++ b/example/websocket_tls.cpp @@ -80,7 +80,7 @@ void publish_qos0_websocket_tls() { tls_context.set_verify_mode(asio::ssl::verify_peer); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.credentials("test-qos0-websocket-tls", "", "") .brokers("emqtt.mireo.local/mqtt", 8884) @@ -115,7 +115,7 @@ void publish_qos1_websocket_tls() { tls_context.set_verify_mode(asio::ssl::verify_peer); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.credentials("test-qos1-websocket-tls", "", "") .brokers("emqtt.mireo.local/mqtt", 8884) @@ -151,7 +151,7 @@ void publish_qos2_websocket_tls() { tls_context.set_verify_mode(asio::ssl::verify_peer); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.credentials("test-qos2-websocket-tls", "", "") .brokers("emqtt.mireo.local/mqtt", 8884) @@ -188,7 +188,7 @@ void subscribe_and_receive_websocket_tls(int num_receive) { tls_context.set_verify_mode(asio::ssl::verify_peer); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.credentials("test-subscriber-websocket-tls", "", "") .brokers("emqtt.mireo.local/mqtt", 8884) diff --git a/include/async_mqtt5/impl/client_service.hpp b/include/async_mqtt5/impl/client_service.hpp index 5787ac8..a35e42a 100644 --- a/include/async_mqtt5/impl/client_service.hpp +++ b/include/async_mqtt5/impl/client_service.hpp @@ -254,7 +254,6 @@ public: client_service( const executor_type& ex, - const std::string& /* cnf */, tls_context_type tls_context = {} ) : _executor(ex), diff --git a/include/async_mqtt5/mqtt_client.hpp b/include/async_mqtt5/mqtt_client.hpp index 6f1853c..3ec6aea 100644 --- a/include/async_mqtt5/mqtt_client.hpp +++ b/include/async_mqtt5/mqtt_client.hpp @@ -54,16 +54,14 @@ public: * \brief Constructs a Client with given parameters. * * \param ex An executor that will be associated with the Client. - * \param cnf * \param tls_context A context object used in TLS/SLL connection. */ explicit mqtt_client( const executor_type& ex, - const std::string& cnf, TlsContext tls_context = {} ) : _impl(std::make_shared( - ex, cnf, std::move(tls_context) + ex, std::move(tls_context) )) {} @@ -72,7 +70,6 @@ public: * * \tparam \__ExecutionContext\__ Type of a concrete execution context. * \param context Execution context whose executor will be associated with the Client. - * \param cnf * \param tls_context A context object used in TLS/SLL connection. * * \par Precondition @@ -89,10 +86,9 @@ public: > explicit mqtt_client( ExecutionContext& context, - const std::string& cnf, TlsContext tls_context = {} ) : - mqtt_client(context.get_executor(), cnf, std::move(tls_context)) + mqtt_client(context.get_executor(), std::move(tls_context)) {} /** diff --git a/test/include/test_common/test_service.hpp b/test/include/test_common/test_service.hpp index 85ba39e..89a8a95 100644 --- a/test/include/test_common/test_service.hpp +++ b/test/include/test_common/test_service.hpp @@ -26,11 +26,11 @@ class test_service : public async_mqtt5::detail::client_service @@ -67,8 +67,8 @@ template < > class overrun_client : public async_mqtt5::detail::client_service { public: - overrun_client(const asio::any_io_executor& ex, const std::string& cnf) : - async_mqtt5::detail::client_service(ex, cnf) + overrun_client(const asio::any_io_executor& ex) : + async_mqtt5::detail::client_service(ex) {} uint16_t allocate_pid() { diff --git a/test/integration/async_sender.cpp b/test/integration/async_sender.cpp index 88d2fd6..7b72130 100644 --- a/test/integration/async_sender.cpp +++ b/test/integration/async_sender.cpp @@ -77,7 +77,7 @@ BOOST_FIXTURE_TEST_CASE(ordering_after_reconnect, shared_test_data) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); @@ -160,7 +160,7 @@ BOOST_FIXTURE_TEST_CASE(throttling, shared_test_data) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1") .async_run(asio::detached); @@ -218,7 +218,7 @@ BOOST_FIXTURE_TEST_CASE(prioritize_disconnect, shared_test_data) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); diff --git a/test/integration/cancellation.cpp b/test/integration/cancellation.cpp index acc0b08..fe421d3 100644 --- a/test/integration/cancellation.cpp +++ b/test/integration/cancellation.cpp @@ -154,7 +154,7 @@ void run_cancel_op_test() { asio::io_context ioc; asio::cancellation_signal signal; - client_type c(ioc, ""); + client_type c(ioc); c.brokers("127.0.0.1"); setup_cancel_op_test_case(c, signal, handlers_called); @@ -271,7 +271,7 @@ BOOST_FIXTURE_TEST_CASE(rerunning_the_client, shared_test_data) { co_spawn(ioc, [&]() -> asio::awaitable { - mqtt_client c(ioc, ""); + mqtt_client c(ioc); c.brokers("127.0.0.1,127.0.0.1", 1883) // to avoid reconnect backoff .async_run(asio::detached); diff --git a/test/integration/coroutine.cpp b/test/integration/coroutine.cpp index e7cd79f..120ed8e 100644 --- a/test/integration/coroutine.cpp +++ b/test/integration/coroutine.cpp @@ -110,7 +110,7 @@ BOOST_AUTO_TEST_CASE(tcp_client_check) { using stream_type = asio::ip::tcp::socket; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.brokers("broker.hivemq.com", 1883) .will({ "test/mqtt-test", "Client disconnected!", qos_e::at_least_once }) @@ -145,7 +145,7 @@ BOOST_AUTO_TEST_CASE(websocket_tcp_client_check) { >; using client_type = mqtt_client; - client_type c(ioc, ""); + client_type c(ioc); c.brokers("broker.hivemq.com/mqtt", 8000) .will({ "test/mqtt-test", "Client disconnected!", qos_e::at_least_once }) @@ -180,7 +180,7 @@ BOOST_AUTO_TEST_CASE(openssl_tls_client_check) { asio::ssl::context tls_context(asio::ssl::context::tls_client); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.brokers("broker.hivemq.com", 8883) .will({ "test/mqtt-test", "Client disconnected!", qos_e::at_least_once }) @@ -217,7 +217,7 @@ BOOST_AUTO_TEST_CASE(websocket_tls_client_check) { asio::ssl::context tls_context(asio::ssl::context::tls_client); using client_type = mqtt_client; - client_type c(ioc, "", std::move(tls_context)); + client_type c(ioc, std::move(tls_context)); c.brokers("broker.hivemq.com/mqtt", 8884) .will({ "test/mqtt-test", "Client disconnected!", qos_e::at_least_once }) diff --git a/test/integration/executors.cpp b/test/integration/executors.cpp index 848c0d8..b559869 100644 --- a/test/integration/executors.cpp +++ b/test/integration/executors.cpp @@ -100,7 +100,7 @@ BOOST_AUTO_TEST_CASE(async_run) { auto strand = asio::make_strand(ioc); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1") .async_run(asio::bind_executor( strand, diff --git a/test/integration/ping.cpp b/test/integration/ping.cpp index 1dfc619..d5ea986 100644 --- a/test/integration/ping.cpp +++ b/test/integration/ping.cpp @@ -56,7 +56,7 @@ void run_test( ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .keep_alive(keep_alive) .async_run(asio::detached); diff --git a/test/integration/re_authentication.cpp b/test/integration/re_authentication.cpp index 39f2856..add9b21 100644 --- a/test/integration/re_authentication.cpp +++ b/test/integration/re_authentication.cpp @@ -65,7 +65,7 @@ void run_test( ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1"); if constexpr (!std::is_same_v) diff --git a/test/integration/read_message.cpp b/test/integration/read_message.cpp index 8059505..ee112ba 100644 --- a/test/integration/read_message.cpp +++ b/test/integration/read_message.cpp @@ -53,7 +53,7 @@ void test_receive_malformed_packet( ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); @@ -146,7 +146,7 @@ BOOST_FIXTURE_TEST_CASE(receive_disconnect, shared_test_data) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); @@ -173,7 +173,7 @@ void run_receive_test( ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); diff --git a/test/integration/receive_publish.cpp b/test/integration/receive_publish.cpp index a63fd06..77f4281 100644 --- a/test/integration/receive_publish.cpp +++ b/test/integration/receive_publish.cpp @@ -63,7 +63,7 @@ void run_test( ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .connect_properties(cprops) .async_run(asio::detached); @@ -376,7 +376,7 @@ BOOST_FIXTURE_TEST_CASE(receive_buffer_overflow, shared_test_data) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1") .async_run(asio::detached); diff --git a/test/integration/send_publish.cpp b/test/integration/send_publish.cpp index 386ee60..645a3c4 100644 --- a/test/integration/send_publish.cpp +++ b/test/integration/send_publish.cpp @@ -62,7 +62,7 @@ void run_test( ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); @@ -506,7 +506,7 @@ BOOST_FIXTURE_TEST_CASE(cancel_resending_publish, shared_test_data) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); @@ -585,7 +585,7 @@ BOOST_FIXTURE_TEST_CASE(send_big_publish, shared_test_data) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); diff --git a/test/integration/sub_unsub.cpp b/test/integration/sub_unsub.cpp index ff71771..95b0d4c 100644 --- a/test/integration/sub_unsub.cpp +++ b/test/integration/sub_unsub.cpp @@ -68,7 +68,7 @@ void run_test(test::msg_exchange broker_side) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); @@ -395,7 +395,7 @@ void run_cancellation_test(test::msg_exchange broker_side) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1,127.0.0.1") // to avoid reconnect backoff .async_run(asio::detached); diff --git a/test/unit/compilation_checks.cpp b/test/unit/compilation_checks.cpp index e5074fe..794dfc8 100644 --- a/test/unit/compilation_checks.cpp +++ b/test/unit/compilation_checks.cpp @@ -93,7 +93,7 @@ BOOST_AUTO_TEST_CASE(async_traits) { BOOST_AUTO_TEST_CASE(client_functions) { asio::io_context ioc; - mqtt_client tcp_client(ioc, ""); + mqtt_client tcp_client(ioc); tcp_client.authenticator(good_authenticator()); connack_props ca_props; @@ -122,7 +122,7 @@ BOOST_AUTO_TEST_CASE(client_functions) { asio::ssl::context ctx(asio::ssl::context::tls_client); mqtt_client< tls_layer, asio::ssl::context - > tls_client(ioc.get_executor(), "", std::move(ctx)); + > tls_client(ioc.get_executor(), std::move(ctx)); tls_client.tls_context(); } diff --git a/test/unit/disconnect_op.cpp b/test/unit/disconnect_op.cpp index 30a73e8..087312d 100644 --- a/test/unit/disconnect_op.cpp +++ b/test/unit/disconnect_op.cpp @@ -25,7 +25,6 @@ void run_malformed_props_test(const disconnect_props& dprops) { using client_service_type = test::test_service; auto svc_ptr = std::make_shared(ioc.get_executor()); - auto handler = [&handlers_called](error_code ec) { ++handlers_called; BOOST_TEST(ec == client::error::malformed_packet); @@ -102,7 +101,7 @@ BOOST_AUTO_TEST_CASE(omit_props) { ); using client_type = mqtt_client; - client_type c(executor, ""); + client_type c(executor); c.brokers("127.0.0.1") .async_run(asio::detached); diff --git a/test/unit/publish_send_op.cpp b/test/unit/publish_send_op.cpp index 048353d..a1eb277 100644 --- a/test/unit/publish_send_op.cpp +++ b/test/unit/publish_send_op.cpp @@ -20,7 +20,7 @@ BOOST_AUTO_TEST_CASE(pid_overrun) { asio::io_context ioc; using client_service_type = test::overrun_client; - auto svc_ptr = std::make_shared(ioc.get_executor(), ""); + auto svc_ptr = std::make_shared(ioc.get_executor()); auto handler = [&handlers_called](error_code ec, reason_code rc, puback_props) { ++handlers_called; diff --git a/test/unit/subscribe_op.cpp b/test/unit/subscribe_op.cpp index ca435e0..ca007b3 100644 --- a/test/unit/subscribe_op.cpp +++ b/test/unit/subscribe_op.cpp @@ -16,7 +16,7 @@ BOOST_AUTO_TEST_CASE(pid_overrun) { asio::io_context ioc; using client_service_type = test::overrun_client; - auto svc_ptr = std::make_shared(ioc.get_executor(), ""); + auto svc_ptr = std::make_shared(ioc.get_executor()); auto handler = [&handlers_called](error_code ec, std::vector rcs, suback_props) { ++handlers_called; diff --git a/test/unit/unsubscribe_op.cpp b/test/unit/unsubscribe_op.cpp index 9135e5b..499a61a 100644 --- a/test/unit/unsubscribe_op.cpp +++ b/test/unit/unsubscribe_op.cpp @@ -16,7 +16,7 @@ BOOST_AUTO_TEST_CASE(pid_overrun) { asio::io_context ioc; using client_service_type = test::overrun_client; - auto svc_ptr = std::make_shared(ioc.get_executor(), ""); + auto svc_ptr = std::make_shared(ioc.get_executor()); auto handler = [&handlers_called](error_code ec, std::vector rcs, unsuback_props) { ++handlers_called;